home *** CD-ROM | disk | FTP | other *** search
MacBinary | 1993-01-18 | 24.5 KB | [ TEXT/MPS ]
open in: MacOS 8.1
extracted
|
Win98
extracted
|
DOS
extracted
browse contents |
view JSON data
|
view as text
This file was processed as: MacBinary
(archive/macBinary ).
Confidence Program Detection Match Type Support
10%
dexvert
MacBinary (archive/macBinary)
fallback
Supported
1%
dexvert
MS-DOS Code Page Info (other/dosCodePage)
ext
Unsupported
1%
dexvert
Text File (text/txt)
fallback
Supported
100%
file
MacBinary II, Sun Jan 17 20:10:03 1993, modified Sun Jan 17 20:10:03 1993, creator 'MPS ', type ASCII, 24169 bytes "GUSIUnix.cp" , at 0x5ee9 748 bytes resource
default (weak)
99%
file
data
default
74%
TrID
Macintosh plain text (MacBinary)
default
25%
TrID
MacBinary 2
default (weak)
100%
siegfried
fmt/1762 MacBinary (II)
default
100%
lsar
MacBinary
default
id metadata key value macFileType [ TEXT] macFileCreator [ MPS ]
hex view +--------+-------------------------+-------------------------+--------+--------+ |00000000| 00 0b 47 55 53 49 55 6e | 69 78 2e 63 70 00 00 00 |..GUSIUn|ix.cp...| |00000010| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| |00000020| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| |00000030| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| |00000040| 00 54 45 58 54 4d 50 53 | 20 00 00 00 00 00 00 00 |.TEXTMPS| .......| |00000050| 00 00 00 00 00 5e 69 00 | 00 02 ec a7 7f b3 eb a7 |.....^i.|........| |00000060| 7f b3 eb 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| |00000070| 00 00 00 00 00 00 00 00 | 00 00 81 81 e2 3c 00 00 |........|.....<..| |00000080| 2f 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |/*******|********| |00000090| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |000000a0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |000000b0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |000000c0| 2a 2a 2a 2a 2a 2a 0d 50 | 72 6f 6a 65 63 74 09 3a |******.P|roject.:| |000000d0| 09 47 55 53 49 09 09 09 | 09 2d 09 47 72 61 6e 64 |.GUSI...|.-.Grand| |000000e0| 20 55 6e 69 66 69 65 64 | 20 53 6f 63 6b 65 74 20 | Unified| Socket | |000000f0| 49 6e 74 65 72 66 61 63 | 65 0d 46 69 6c 65 09 09 |Interfac|e.File..| |00000100| 3a 09 47 55 53 49 55 6e | 69 78 2e 63 70 09 09 2d |:.GUSIUn|ix.cp..-| |00000110| 09 49 6d 70 6c 65 6d 65 | 6e 74 61 74 69 6f 6e 20 |.Impleme|ntation | |00000120| 6f 66 20 55 6e 69 78 20 | 64 6f 6d 61 69 6e 20 63 |of Unix |domain c| |00000130| 61 6c 6c 73 0d 41 75 74 | 68 6f 72 09 3a 09 4d 61 |alls.Aut|hor.:.Ma| |00000140| 74 74 68 69 61 73 20 4e | 65 65 72 61 63 68 65 72 |tthias N|eeracher| |00000150| 0d 53 74 61 72 74 65 64 | 09 3a 09 33 31 4d 61 72 |.Started|.:.31Mar| |00000160| 39 32 09 09 09 09 09 09 | 09 09 4c 61 6e 67 75 61 |92......|..Langua| |00000170| 67 65 09 3a 09 4d 50 57 | 20 43 2f 43 2b 2b 0d 4d |ge.:.MPW| C/C++.M| |00000180| 6f 64 69 66 69 65 64 09 | 3a 09 33 31 4d 61 72 39 |odified.|:.31Mar9| |00000190| 32 09 4d 4e 09 75 6e 69 | 78 20 64 6f 6d 61 69 6e |2.MN.uni|x domain| |000001a0| 20 73 6f 63 6b 65 74 20 | 63 61 6c 6c 73 0d 09 09 | socket |calls...| |000001b0| 09 09 31 38 41 70 72 39 | 32 09 4d 4e 09 4f 6e 20 |..18Apr9|2.MN.On | |000001c0| 77 69 74 68 20 74 68 65 | 20 73 68 6f 77 2c 20 67 |with the| show, g| |000001d0| 6f 6f 64 20 68 65 61 6c | 74 68 20 74 6f 20 79 6f |ood heal|th to yo| |000001e0| 75 0d 09 09 09 09 32 30 | 41 70 72 39 32 09 4d 4e |u.....20|Apr92.MN| |000001f0| 09 43 2b 2b 20 72 65 77 | 72 69 74 65 0d 09 09 09 |.C++ rew|rite....| |00000200| 09 32 34 41 70 72 39 32 | 09 4d 4e 09 49 6e 74 72 |.24Apr92|.MN.Intr| |00000210| 6f 64 75 63 69 6e 67 20 | 55 6e 69 78 53 74 72 65 |oducing |UnixStre| |00000220| 61 6d 53 6f 63 6b 65 74 | 2c 20 55 6e 69 78 44 67 |amSocket|, UnixDg| |00000230| 72 61 6d 53 6f 63 6b 65 | 74 0d 09 09 09 09 32 31 |ramSocke|t.....21| |00000240| 4d 61 79 39 32 09 4d 4e | 09 49 6d 70 6c 65 6d 65 |May92.MN|.Impleme| |00000250| 6e 74 65 64 20 73 65 6c | 65 63 74 28 29 0d 09 09 |nted sel|ect()...| |00000260| 09 09 31 33 4a 75 6c 39 | 32 09 4d 4e 09 49 6e 20 |..13Jul9|2.MN.In | |00000270| 73 70 69 72 69 74 20 6f | 66 20 55 6e 69 78 20 69 |spirit o|f Unix i| |00000280| 6d 70 6c 65 6d 65 6e 74 | 61 74 69 6f 6e 2c 20 75 |mplement|ation, u| |00000290| 73 65 20 66 69 6c 65 2c | 20 6e 6f 74 20 68 61 73 |se file,| not has| |000002a0| 68 20 74 61 62 6c 65 0d | 09 09 09 09 32 36 4a 75 |h table.|....26Ju| |000002b0| 6c 39 32 09 4d 4e 09 45 | 72 72 6f 72 20 69 6e 20 |l92.MN.E|rror in | |000002c0| 75 73 69 6e 67 20 6d 65 | 6d 63 63 70 79 28 29 0d |using me|mccpy().| |000002d0| 09 09 09 09 31 30 41 75 | 67 39 32 09 4d 4e 09 73 |....10Au|g92.MN.s| |000002e0| 65 6c 65 63 74 28 29 20 | 66 6f 72 20 61 63 63 65 |elect() |for acce| |000002f0| 70 74 2f 63 6f 6e 6e 65 | 63 74 0d 09 09 09 09 31 |pt/conne|ct.....1| |00000300| 32 53 65 70 39 32 09 4d | 4e 09 52 65 6e 61 6d 65 |2Sep92.M|N.Rename| |00000310| 64 20 50 61 74 68 73 2e | 68 20 74 6f 20 47 55 53 |d Paths.|h to GUS| |00000320| 49 46 53 70 5f 50 2e 68 | 0d 09 09 09 09 31 33 53 |IFSp_P.h|.....13S| |00000330| 65 70 39 32 09 4d 4e 09 | 41 6c 77 61 79 73 20 63 |ep92.MN.|Always c| |00000340| 6f 6d 70 6c 65 74 65 20 | 77 72 69 74 65 0d 09 09 |omplete |write...| |00000350| 09 09 31 35 4e 6f 76 39 | 32 09 4d 4e 09 52 65 6e |..15Nov9|2.MN.Ren| |00000360| 61 6d 65 20 47 55 53 49 | 46 53 70 5f 50 2e 68 20 |ame GUSI|FSp_P.h | |00000370| 74 6f 20 54 46 69 6c 65 | 53 70 65 63 2e 68 20 28 |to TFile|Spec.h (| |00000380| 74 68 65 72 65 20 77 65 | 20 67 6f 20 61 67 61 69 |there we| go agai| |00000390| 6e 29 0d 09 09 09 09 31 | 37 4a 61 6e 39 33 09 4d |n).....1|7Jan93.M| |000003a0| 4e 09 42 65 20 6d 6f 72 | 65 20 63 61 72 65 66 75 |N.Be mor|e carefu| |000003b0| 6c 20 61 62 6f 75 74 20 | 55 73 65 72 20 69 6e 74 |l about |User int| |000003c0| 65 72 72 75 70 74 73 0d | 4c 61 73 74 09 09 3a 09 |errupts.|Last..:.| |000003d0| 31 37 4a 61 6e 39 33 0d | 2a 2a 2a 2a 2a 2a 2a 2a |17Jan93.|********| |000003e0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |000003f0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00000400| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00000410| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2f 0d 0d |********|*****/..| |00000420| 23 69 6e 63 6c 75 64 65 | 20 22 47 55 53 49 5f 50 |#include| "GUSI_P| |00000430| 2e 68 22 0d 23 69 6e 63 | 6c 75 64 65 20 22 54 46 |.h".#inc|lude "TF| |00000440| 69 6c 65 53 70 65 63 2e | 68 22 0d 0d 23 69 6e 63 |ileSpec.|h"..#inc| |00000450| 6c 75 64 65 20 3c 50 72 | 6f 63 65 73 73 65 73 2e |lude <Pr|ocesses.| |00000460| 68 3e 0d 23 69 6e 63 6c | 75 64 65 20 3c 52 65 73 |h>.#incl|ude <Res| |00000470| 6f 75 72 63 65 73 2e 68 | 3e 0d 23 69 6e 63 6c 75 |ources.h|>.#inclu| |00000480| 64 65 20 3c 53 79 73 45 | 71 75 2e 68 3e 0d 23 69 |de <SysE|qu.h>.#i| |00000490| 6e 63 6c 75 64 65 20 3c | 46 69 6e 64 65 72 2e 68 |nclude <|Finder.h| |000004a0| 3e 0d 0d 23 70 72 61 67 | 6d 61 20 66 6f 72 63 65 |>..#prag|ma force| |000004b0| 5f 61 63 74 69 76 65 20 | 6f 6e 0d 23 70 72 61 67 |_active |on.#prag| |000004c0| 6d 61 20 73 65 67 6d 65 | 6e 74 20 47 55 53 49 55 |ma segme|nt GUSIU| |000004d0| 6e 69 78 0d 0d 63 6c 61 | 73 73 20 55 6e 69 78 53 |nix..cla|ss UnixS| |000004e0| 6f 63 6b 65 74 44 6f 6d | 61 69 6e 20 3a 20 70 75 |ocketDom|ain : pu| |000004f0| 62 6c 69 63 20 53 6f 63 | 6b 65 74 44 6f 6d 61 69 |blic Soc|ketDomai| |00000500| 6e 20 7b 0d 70 75 62 6c | 69 63 3a 0d 09 55 6e 69 |n {.publ|ic:..Uni| |00000510| 78 53 6f 63 6b 65 74 44 | 6f 6d 61 69 6e 28 29 09 |xSocketD|omain().| |00000520| 3a 09 53 6f 63 6b 65 74 | 44 6f 6d 61 69 6e 28 41 |:.Socket|Domain(A| |00000530| 46 5f 55 4e 49 58 29 09 | 7b 09 09 7d 0d 0d 09 76 |F_UNIX).|{..}...v| |00000540| 69 72 74 75 61 6c 20 53 | 6f 63 6b 65 74 20 2a 20 |irtual S|ocket * | |00000550| 09 73 6f 63 6b 65 74 28 | 69 6e 74 20 74 79 70 65 |.socket(|int type| |00000560| 2c 20 73 68 6f 72 74 20 | 70 72 6f 74 6f 63 6f 6c |, short |protocol| |00000570| 29 3b 0d 09 76 69 72 74 | 75 61 6c 20 69 6e 74 20 |);..virt|ual int | |00000580| 09 09 63 68 6f 6f 73 65 | 28 0d 09 09 09 09 09 09 |..choose|(.......| |00000590| 09 09 69 6e 74 20 09 09 | 74 79 70 65 2c 20 0d 09 |..int ..|type, ..| |000005a0| 09 09 09 09 09 09 09 63 | 68 61 72 20 2a 20 09 70 |.......c|har * .p| |000005b0| 72 6f 6d 70 74 2c 20 0d | 09 09 09 09 09 09 09 09 |rompt, .|........| |000005c0| 76 6f 69 64 20 2a 20 09 | 63 6f 6e 73 74 72 61 69 |void * .|constrai| |000005d0| 6e 74 2c 09 09 0d 09 09 | 09 09 09 09 09 09 69 6e |nt,.....|......in| |000005e0| 74 20 09 09 66 6c 61 67 | 73 2c 0d 20 09 09 09 09 |t ..flag|s,. ....| |000005f0| 09 09 09 09 76 6f 69 64 | 20 2a 20 09 6e 61 6d 65 |....void| * .name| |00000600| 2c 20 0d 09 09 09 09 09 | 09 09 09 69 6e 74 20 2a |, ......|...int *| |00000610| 20 09 6e 61 6d 65 6c 65 | 6e 29 3b 0d 7d 3b 0d 0d | .namele|n);.};..| |00000620| 73 74 61 74 69 63 20 55 | 6e 69 78 53 6f 63 6b 65 |static U|nixSocke| |00000630| 74 44 6f 6d 61 69 6e 09 | 55 6e 69 78 53 6f 63 6b |tDomain.|UnixSock| |00000640| 65 74 73 3b 0d 0d 63 6c | 61 73 73 20 55 6e 69 78 |ets;..cl|ass Unix| |00000650| 53 6f 63 6b 65 74 3b 09 | 09 09 09 09 09 09 09 09 |Socket;.|........| |00000660| 2f 2f 20 54 68 61 74 27 | 73 20 77 68 61 74 20 74 |// That'|s what t| |00000670| 68 69 73 20 66 69 6c 65 | 27 73 20 61 6c 6c 20 61 |his file|'s all a| |00000680| 62 6f 75 74 0d 63 6c 61 | 73 73 20 55 6e 69 78 53 |bout.cla|ss UnixS| |00000690| 74 72 65 61 6d 53 6f 63 | 6b 65 74 3b 0d 63 6c 61 |treamSoc|ket;.cla| |000006a0| 73 73 20 55 6e 69 78 44 | 67 72 61 6d 53 6f 63 6b |ss UnixD|gramSock| |000006b0| 65 74 3b 0d 0d 73 74 72 | 75 63 74 20 55 6e 69 78 |et;..str|uct Unix| |000006c0| 53 6f 63 6b 65 74 41 64 | 64 72 20 3a 20 54 46 69 |SocketAd|dr : TFi| |000006d0| 6c 65 53 70 65 63 20 7b | 0d 09 42 6f 6f 6c 65 61 |leSpec {|..Boolea| |000006e0| 6e 09 09 76 61 6c 69 64 | 3b 0d 09 42 6f 6f 6c 65 |n..valid|;..Boole| |000006f0| 61 6e 09 09 6f 77 6e 65 | 64 3b 0d 09 0d 09 55 6e |an..owne|d;....Un| |00000700| 69 78 53 6f 63 6b 65 74 | 41 64 64 72 28 29 3b 0d |ixSocket|Addr();.| |00000710| 09 55 6e 69 78 53 6f 63 | 6b 65 74 41 64 64 72 28 |.UnixSoc|ketAddr(| |00000720| 54 46 69 6c 65 53 70 65 | 63 20 73 70 65 63 29 3b |TFileSpe|c spec);| |00000730| 0d 7d 3b 0d 0d 2f 2f 20 | 54 68 65 20 69 6e 74 65 |.};..// |The inte| |00000740| 72 66 61 63 65 20 6f 66 | 20 74 68 69 73 20 63 6c |rface of| this cl| |00000750| 61 73 73 20 73 68 6f 75 | 6c 64 20 6e 65 76 65 72 |ass shou|ld never| |00000760| 20 62 65 20 63 68 61 6e | 67 65 64 20 6e 6f 77 20 | be chan|ged now | |00000770| 74 68 65 20 66 69 72 73 | 74 20 76 65 72 73 69 6f |the firs|t versio| |00000780| 6e 20 0d 2f 2f 20 6f 66 | 20 47 55 53 49 20 69 73 |n .// of| GUSI is| |00000790| 20 72 65 6c 65 61 73 65 | 64 2e 20 41 6c 6c 20 66 | release|d. All f| |000007a0| 75 72 74 68 65 72 20 63 | 68 61 6e 67 65 73 20 73 |urther c|hanges s| |000007b0| 68 6f 75 6c 64 20 62 65 | 20 64 6f 6e 65 20 62 79 |hould be| done by| |000007c0| 20 6d 61 6b 69 6e 67 20 | 61 20 73 75 62 63 6c 61 | making |a subcla| |000007d0| 73 73 2e 0d 2f 2f 20 54 | 68 65 20 56 65 72 73 69 |ss..// T|he Versi| |000007e0| 6f 6e 28 29 20 6d 65 74 | 68 6f 64 20 6d 75 73 74 |on() met|hod must| |000007f0| 20 72 65 74 75 72 6e 20 | 2a 69 6e 63 72 65 61 73 | return |*increas| |00000800| 69 6e 67 2a 20 76 65 72 | 73 69 6f 6e 20 6e 75 6d |ing* ver|sion num| |00000810| 62 65 72 73 2e 0d 0d 2f | 2f 20 56 65 72 73 69 6f |bers.../|/ Versio| |00000820| 6e 20 32 20 61 64 64 73 | 20 73 75 70 70 6f 72 74 |n 2 adds| support| |00000830| 20 66 6f 72 20 61 62 6f | 72 74 69 6e 67 20 61 20 | for abo|rting a | |00000840| 63 6f 6e 6e 65 63 74 69 | 6f 6e 2c 20 73 65 65 20 |connecti|on, see | |00000850| 62 65 6c 6f 77 0d 0d 63 | 6c 61 73 73 20 55 6e 69 |below..c|lass Uni| |00000860| 78 43 68 61 6e 6e 65 6c | 20 3a 20 70 75 62 6c 69 |xChannel| : publi| |00000870| 63 20 53 69 6e 67 6c 65 | 4f 62 6a 65 63 74 20 7b |c Single|Object {| |00000880| 0d 09 55 6e 69 78 53 6f | 63 6b 65 74 41 64 64 72 |..UnixSo|cketAddr| |00000890| 09 61 64 64 72 65 73 73 | 3b 0d 09 0d 09 76 6f 69 |.address|;....voi| |000008a0| 64 20 55 6e 42 69 6e 64 | 28 29 3b 0d 70 72 6f 74 |d UnBind|();.prot| |000008b0| 65 63 74 65 64 3a 0d 09 | 55 6e 69 78 53 6f 63 6b |ected:..|UnixSock| |000008c0| 65 74 20 2a 20 09 73 6f | 63 6b 3b 0d 70 75 62 6c |et * .so|ck;.publ| |000008d0| 69 63 3a 0d 09 55 6e 69 | 78 43 68 61 6e 6e 65 6c |ic:..Uni|xChannel| |000008e0| 09 2a 09 6e 65 78 74 4c | 69 73 74 65 6e 65 72 3b |.*.nextL|istener;| |000008f0| 0d 09 69 6e 74 09 09 09 | 09 65 72 72 6e 6f 3b 0d |..int...|.errno;.| |00000900| 09 0d 09 55 6e 69 78 43 | 68 61 6e 6e 65 6c 28 55 |...UnixC|hannel(U| |00000910| 6e 69 78 53 6f 63 6b 65 | 74 20 2a 20 6f 77 6e 65 |nixSocke|t * owne| |00000920| 72 29 3b 0d 09 76 69 72 | 74 75 61 6c 20 7e 55 6e |r);..vir|tual ~Un| |00000930| 69 78 43 68 61 6e 6e 65 | 6c 28 29 3b 0d 09 0d 09 |ixChanne|l();....| |00000940| 76 69 72 74 75 61 6c 20 | 69 6e 74 09 09 09 56 65 |virtual |int...Ve| |00000950| 72 73 69 6f 6e 28 29 3b | 0d 09 0d 09 76 69 72 74 |rsion();|....virt| |00000960| 75 61 6c 20 42 6f 6f 6c | 65 61 6e 09 42 69 6e 64 |ual Bool|ean.Bind| |00000970| 28 55 6e 69 78 53 6f 63 | 6b 65 74 41 64 64 72 20 |(UnixSoc|ketAddr | |00000980| 26 20 61 64 64 72 29 3b | 0d 09 76 69 72 74 75 61 |& addr);|..virtua| |00000990| 6c 20 42 6f 6f 6c 65 61 | 6e 09 43 6f 6e 6e 65 63 |l Boolea|n.Connec| |000009a0| 74 28 55 6e 69 78 43 68 | 61 6e 6e 65 6c 20 2a 20 |t(UnixCh|annel * | |000009b0| 63 68 29 3b 0d 09 76 69 | 72 74 75 61 6c 20 42 6f |ch);..vi|rtual Bo| |000009c0| 6f 6c 65 61 6e 09 41 63 | 63 65 70 74 28 55 6e 69 |olean.Ac|cept(Uni| |000009d0| 78 43 68 61 6e 6e 65 6c | 20 2a 20 63 68 29 3b 0d |xChannel| * ch);.| |000009e0| 0d 09 76 69 72 74 75 61 | 6c 20 69 6e 74 09 09 09 |..virtua|l int...| |000009f0| 52 65 61 64 28 76 6f 69 | 64 20 2a 20 62 75 66 66 |Read(voi|d * buff| |00000a00| 65 72 2c 20 69 6e 74 20 | 6c 65 6e 29 3b 0d 09 76 |er, int |len);..v| |00000a10| 69 72 74 75 61 6c 20 69 | 6e 74 09 09 09 57 72 69 |irtual i|nt...Wri| |00000a20| 74 65 28 76 6f 69 64 20 | 2a 20 62 75 66 66 65 72 |te(void |* buffer| |00000a30| 2c 20 69 6e 74 20 6c 65 | 6e 29 3b 0d 09 76 69 72 |, int le|n);..vir| |00000a40| 74 75 61 6c 20 69 6e 74 | 09 09 09 53 65 6e 64 28 |tual int|...Send(| |00000a50| 55 6e 69 78 43 68 61 6e | 6e 65 6c 20 2a 20 66 72 |UnixChan|nel * fr| |00000a60| 6f 6d 2c 20 76 6f 69 64 | 20 2a 20 62 75 66 66 65 |om, void| * buffe| |00000a70| 72 2c 20 69 6e 74 20 6c | 65 6e 29 3b 0d 09 76 69 |r, int l|en);..vi| |00000a80| 72 74 75 61 6c 20 69 6e | 74 20 09 09 52 65 61 64 |rtual in|t ..Read| |00000a90| 41 76 61 69 6c 28 29 3b | 0d 09 76 69 72 74 75 61 |Avail();|..virtua| |00000aa0| 6c 20 69 6e 74 09 09 09 | 57 72 69 74 65 41 76 61 |l int...|WriteAva| |00000ab0| 69 6c 28 29 3b 0d 09 76 | 69 72 74 75 61 6c 20 69 |il();..v|irtual i| |00000ac0| 6e 74 09 09 09 42 75 66 | 53 69 7a 65 28 29 3b 0d |nt...Buf|Size();.| |00000ad0| 09 76 69 72 74 75 61 6c | 20 76 6f 69 64 20 09 09 |.virtual| void ..| |00000ae0| 44 69 73 63 61 72 64 52 | 65 61 64 28 69 6e 74 20 |DiscardR|ead(int | |00000af0| 6c 65 6e 29 3b 0d 09 76 | 69 72 74 75 61 6c 20 76 |len);..v|irtual v| |00000b00| 6f 69 64 20 09 09 53 68 | 75 74 44 6f 77 6e 28 69 |oid ..Sh|utDown(i| |00000b10| 6e 74 20 68 6f 77 29 3b | 0d 09 76 69 72 74 75 61 |nt how);|..virtua| |00000b20| 6c 20 76 6f 69 64 09 09 | 44 69 73 63 6f 6e 6e 65 |l void..|Disconne| |00000b30| 63 74 28 29 3b 0d 09 0d | 09 76 69 72 74 75 61 6c |ct();...|.virtual| |00000b40| 20 69 6e 74 09 09 09 47 | 55 53 49 5f 65 72 72 6f | int...G|USI_erro| |00000b50| 72 28 69 6e 74 20 65 72 | 72 29 3b 0d 0d 09 76 69 |r(int er|r);...vi| |00000b60| 72 74 75 61 6c 20 55 6e | 69 78 53 6f 63 6b 65 74 |rtual Un|ixSocket| |00000b70| 41 64 64 72 20 26 20 0d | 09 09 09 09 09 09 09 41 |Addr & .|.......A| |00000b80| 64 64 72 65 73 73 28 29 | 3b 0d 7d 3b 0d 0d 63 6c |ddress()|;.};..cl| |00000b90| 61 73 73 20 55 6e 69 78 | 43 68 61 6e 6e 65 6c 32 |ass Unix|Channel2| |00000ba0| 20 3a 20 70 75 62 6c 69 | 63 20 55 6e 69 78 43 68 | : publi|c UnixCh| |00000bb0| 61 6e 6e 65 6c 20 7b 0d | 70 75 62 6c 69 63 3a 0d |annel {.|public:.| |00000bc0| 09 55 6e 69 78 43 68 61 | 6e 6e 65 6c 32 28 55 6e |.UnixCha|nnel2(Un| |00000bd0| 69 78 53 6f 63 6b 65 74 | 20 2a 20 6f 77 6e 65 72 |ixSocket| * owner| |00000be0| 29 3b 0d 0d 09 76 69 72 | 74 75 61 6c 20 69 6e 74 |);...vir|tual int| |00000bf0| 09 09 09 56 65 72 73 69 | 6f 6e 28 29 3b 0d 09 76 |...Versi|on();..v| |00000c00| 69 72 74 75 61 6c 20 76 | 6f 69 64 09 09 4f 72 70 |irtual v|oid..Orp| |00000c10| 68 61 6e 28 29 3b 0d 09 | 76 69 72 74 75 61 6c 20 |han();..|virtual | |00000c20| 76 6f 69 64 09 09 41 62 | 6f 72 74 43 6f 6e 6e 65 |void..Ab|ortConne| |00000c30| 63 74 28 55 6e 69 78 43 | 68 61 6e 6e 65 6c 20 2a |ct(UnixC|hannel *| |00000c40| 20 63 68 29 3b 0d 7d 3b | 0d 0d 63 6c 61 73 73 20 | ch);.};|..class | |00000c50| 55 6e 69 78 53 6f 63 6b | 65 74 20 3a 20 70 75 62 |UnixSock|et : pub| |00000c60| 6c 69 63 20 53 6f 63 6b | 65 74 20 7b 0d 09 66 72 |lic Sock|et {..fr| |00000c70| 69 65 6e 64 20 63 6c 61 | 73 73 20 55 6e 69 78 43 |iend cla|ss UnixC| |00000c80| 68 61 6e 6e 65 6c 3b 0d | 09 66 72 69 65 6e 64 20 |hannel;.|.friend | |00000c90| 63 6c 61 73 73 20 55 6e | 69 78 43 68 61 6e 6e 65 |class Un|ixChanne| |00000ca0| 6c 32 3b 0d 70 72 6f 74 | 65 63 74 65 64 3a 0d 09 |l2;.prot|ected:..| |00000cb0| 63 68 61 72 09 09 09 09 | 73 74 61 74 75 73 3b 0d |char....|status;.| |00000cc0| 09 63 68 61 72 09 09 09 | 09 73 74 61 74 65 3b 0d |.char...|.state;.| |00000cd0| 09 42 6f 6f 6c 65 61 6e | 09 09 09 6e 6f 6e 62 6c |.Boolean|...nonbl| |00000ce0| 6f 63 6b 69 6e 67 3b 0d | 09 63 68 61 72 09 09 09 |ocking;.|.char...| |00000cf0| 09 70 72 6f 74 6f 63 6f | 6c 3b 0d 09 50 74 72 09 |.protoco|l;..Ptr.| |00000d00| 09 09 09 72 65 61 64 42 | 75 66 3b 0d 09 73 68 6f |...readB|uf;..sho| |00000d10| 72 74 09 09 09 09 72 65 | 61 64 42 75 66 53 69 7a |rt....re|adBufSiz| |00000d20| 65 3b 0d 09 73 68 6f 72 | 74 09 09 09 09 72 65 61 |e;..shor|t....rea| |00000d30| 64 50 6f 73 3b 0d 09 73 | 68 6f 72 74 20 09 09 09 |dPos;..s|hort ...| |00000d40| 76 61 6c 69 64 42 79 74 | 65 73 3b 0d 09 73 68 6f |validByt|es;..sho| |00000d50| 72 74 09 09 09 09 63 75 | 72 4c 69 73 74 65 6e 65 |rt....cu|rListene| |00000d60| 72 3b 0d 09 73 68 6f 72 | 74 09 09 09 09 6d 61 78 |r;..shor|t....max| |00000d70| 4c 69 73 74 65 6e 65 72 | 3b 0d 09 55 6e 69 78 43 |Listener|;..UnixC| |00000d80| 68 61 6e 6e 65 6c 20 2a | 09 63 68 61 6e 3b 0d 09 |hannel *|.chan;..| |00000d90| 55 6e 69 78 43 68 61 6e | 6e 65 6c 09 2a 09 70 65 |UnixChan|nel.*.pe| |00000da0| 65 72 3b 0d 09 55 6e 69 | 78 43 68 61 6e 6e 65 6c |er;..Uni|xChannel| |00000db0| 20 2a 09 66 69 72 73 74 | 4c 69 73 74 65 6e 65 72 | *.first|Listener| |00000dc0| 3b 0d 09 55 6e 69 78 43 | 68 61 6e 6e 65 6c 20 2a |;..UnixC|hannel *| |00000dd0| 09 6c 61 73 74 4c 69 73 | 74 65 6e 65 72 3b 0d 0d |.lastLis|tener;..| |00000de0| 09 09 09 09 09 55 6e 69 | 78 53 6f 63 6b 65 74 28 |.....Uni|xSocket(| |00000df0| 73 68 6f 72 74 20 70 72 | 6f 74 29 3b 0d 09 76 6f |short pr|ot);..vo| |00000e00| 69 64 09 09 09 64 65 66 | 61 75 6c 74 62 69 6e 64 |id...def|aultbind| |00000e10| 28 29 3b 0d 70 75 62 6c | 69 63 3a 0d 09 65 6e 75 |();.publ|ic:..enu| |00000e20| 6d 20 7b 63 68 61 6e 6e | 65 6c 55 6e 6b 6e 6f 77 |m {chann|elUnknow| |00000e30| 6e 2c 20 63 68 61 6e 6e | 65 6c 41 6e 63 69 65 6e |n, chann|elAncien| |00000e40| 74 2c 20 63 68 61 6e 6e | 65 6c 53 75 70 70 6f 72 |t, chann|elSuppor| |00000e50| 74 73 43 6f 6e 6e 41 62 | 6f 72 74 7d 3b 0d 09 0d |tsConnAb|ort};...| |00000e60| 09 76 69 72 74 75 61 6c | 20 69 6e 74 09 62 69 6e |.virtual| int.bin| |00000e70| 64 28 76 6f 69 64 20 2a | 20 6e 61 6d 65 2c 20 69 |d(void *| name, i| |00000e80| 6e 74 20 6e 61 6d 65 6c | 65 6e 29 3b 0d 09 76 69 |nt namel|en);..vi| |00000e90| 72 74 75 61 6c 20 69 6e | 74 20 67 65 74 73 6f 63 |rtual in|t getsoc| |00000ea0| 6b 6e 61 6d 65 28 76 6f | 69 64 20 2a 20 6e 61 6d |kname(vo|id * nam| |00000eb0| 65 2c 20 69 6e 74 20 2a | 20 6e 61 6d 65 6c 65 6e |e, int *| namelen| |00000ec0| 29 3b 0d 09 76 69 72 74 | 75 61 6c 20 69 6e 74 20 |);..virt|ual int | |00000ed0| 67 65 74 70 65 65 72 6e | 61 6d 65 28 76 6f 69 64 |getpeern|ame(void| |00000ee0| 20 2a 20 6e 61 6d 65 2c | 20 69 6e 74 20 2a 20 6e | * name,| int * n| |00000ef0| 61 6d 65 6c 65 6e 29 3b | 0d 09 76 69 72 74 75 61 |amelen);|..virtua| |00000f00| 6c 20 69 6e 74 09 66 63 | 6e 74 6c 28 75 6e 73 69 |l int.fc|ntl(unsi| |00000f10| 67 6e 65 64 20 69 6e 74 | 20 63 6d 64 2c 20 69 6e |gned int| cmd, in| |00000f20| 74 20 61 72 67 29 3b 0d | 09 76 69 72 74 75 61 6c |t arg);.|.virtual| |00000f30| 20 69 6e 74 09 69 6f 63 | 74 6c 28 75 6e 73 69 67 | int.ioc|tl(unsig| |00000f40| 6e 65 64 20 69 6e 74 20 | 72 65 71 75 65 73 74 2c |ned int |request,| |00000f50| 20 76 6f 69 64 20 2a 61 | 72 67 70 29 3b 0d 09 76 | void *a|rgp);..v| |00000f60| 69 72 74 75 61 6c 20 69 | 6e 74 20 73 68 75 74 64 |irtual i|nt shutd| |00000f70| 6f 77 6e 28 69 6e 74 20 | 68 6f 77 29 3b 0d 09 76 |own(int |how);..v| |00000f80| 69 72 74 75 61 6c 20 69 | 6e 74 20 73 65 6c 65 63 |irtual i|nt selec| |00000f90| 74 28 42 6f 6f 6c 65 61 | 6e 20 2a 20 63 61 6e 52 |t(Boolea|n * canR| |00000fa0| 65 61 64 2c 20 42 6f 6f | 6c 65 61 6e 20 2a 20 63 |ead, Boo|lean * c| |00000fb0| 61 6e 57 72 69 74 65 2c | 20 42 6f 6f 6c 65 61 6e |anWrite,| Boolean| |00000fc0| 20 2a 20 65 78 63 65 70 | 74 69 6f 6e 29 3b 0d 09 | * excep|tion);..| |00000fd0| 76 69 72 74 75 61 6c 20 | 09 09 7e 55 6e 69 78 53 |virtual |..~UnixS| |00000fe0| 6f 63 6b 65 74 28 29 3b | 0d 7d 3b 0d 0d 63 6c 61 |ocket();|.};..cla| |00000ff0| 73 73 20 55 6e 69 78 53 | 74 72 65 61 6d 53 6f 63 |ss UnixS|treamSoc| |00001000| 6b 65 74 20 3a 20 70 75 | 62 6c 69 63 20 55 6e 69 |ket : pu|blic Uni| |00001010| 78 53 6f 63 6b 65 74 20 | 7b 0d 09 66 72 69 65 6e |xSocket |{..frien| |00001020| 64 20 63 6c 61 73 73 20 | 55 6e 69 78 53 6f 63 6b |d class |UnixSock| |00001030| 65 74 44 6f 6d 61 69 6e | 3b 0d 09 0d 09 09 09 09 |etDomain|;.......| |00001040| 09 55 6e 69 78 53 74 72 | 65 61 6d 53 6f 63 6b 65 |.UnixStr|eamSocke| |00001050| 74 28 29 3b 0d 70 75 62 | 6c 69 63 3a 0d 09 76 69 |t();.pub|lic:..vi| |00001060| 72 74 75 61 6c 20 69 6e | 74 20 6c 69 73 74 65 6e |rtual in|t listen| |00001070| 28 69 6e 74 20 71 6c 65 | 6e 29 3b 0d 09 76 69 72 |(int qle|n);..vir| |00001080| 74 75 61 6c 20 69 6e 74 | 20 63 6f 6e 6e 65 63 74 |tual int| connect| |00001090| 28 76 6f 69 64 20 2a 20 | 61 64 64 72 65 73 73 2c |(void * |address,| |000010a0| 20 69 6e 74 20 61 64 64 | 72 6c 65 6e 29 3b 0d 09 | int add|rlen);..| |000010b0| 76 69 72 74 75 61 6c 20 | 53 6f 63 6b 65 74 20 2a |virtual |Socket *| |000010c0| 20 61 63 63 65 70 74 28 | 76 6f 69 64 20 2a 20 61 | accept(|void * a| |000010d0| 64 64 72 65 73 73 2c 20 | 69 6e 74 20 2a 20 61 64 |ddress, |int * ad| |000010e0| 64 72 6c 65 6e 29 3b 0d | 09 76 69 72 74 75 61 6c |drlen);.|.virtual| |000010f0| 20 69 6e 74 20 72 65 63 | 76 66 72 6f 6d 28 76 6f | int rec|vfrom(vo| |00001100| 69 64 20 2a 20 62 75 66 | 66 65 72 2c 20 69 6e 74 |id * buf|fer, int| |00001110| 20 62 75 66 6c 65 6e 2c | 20 69 6e 74 20 66 6c 61 | buflen,| int fla| |00001120| 67 73 2c 20 76 6f 69 64 | 20 2a 20 66 72 6f 6d 2c |gs, void| * from,| |00001130| 20 69 6e 74 20 2a 20 66 | 72 6f 6d 6c 65 6e 29 3b | int * f|romlen);| |00001140| 0d 09 76 69 72 74 75 61 | 6c 20 69 6e 74 20 73 65 |..virtua|l int se| |00001150| 6e 64 74 6f 28 76 6f 69 | 64 20 2a 20 62 75 66 66 |ndto(voi|d * buff| |00001160| 65 72 2c 20 69 6e 74 20 | 62 75 66 6c 65 6e 2c 20 |er, int |buflen, | |00001170| 69 6e 74 20 66 6c 61 67 | 73 2c 20 76 6f 69 64 20 |int flag|s, void | |00001180| 2a 20 74 6f 2c 20 69 6e | 74 20 74 6f 6c 65 6e 29 |* to, in|t tolen)| |00001190| 3b 0d 09 0d 09 76 69 72 | 74 75 61 6c 20 09 09 7e |;....vir|tual ..~| |000011a0| 55 6e 69 78 53 74 72 65 | 61 6d 53 6f 63 6b 65 74 |UnixStre|amSocket| |000011b0| 28 29 3b 0d 7d 3b 0d 0d | 63 6c 61 73 73 20 55 6e |();.};..|class Un| |000011c0| 69 78 44 67 72 61 6d 53 | 6f 63 6b 65 74 20 3a 20 |ixDgramS|ocket : | |000011d0| 70 75 62 6c 69 63 20 55 | 6e 69 78 53 6f 63 6b 65 |public U|nixSocke| |000011e0| 74 20 7b 0d 09 66 72 69 | 65 6e 64 20 63 6c 61 73 |t {..fri|end clas| |000011f0| 73 20 55 6e 69 78 53 6f | 63 6b 65 74 44 6f 6d 61 |s UnixSo|cketDoma| |00001200| 69 6e 3b 0d 09 0d 09 09 | 09 09 09 55 6e 69 78 44 |in;.....|...UnixD| |00001210| 67 72 61 6d 53 6f 63 6b | 65 74 28 29 3b 0d 70 75 |gramSock|et();.pu| |00001220| 62 6c 69 63 3a 0d 09 76 | 69 72 74 75 61 6c 20 69 |blic:..v|irtual i| |00001230| 6e 74 20 63 6f 6e 6e 65 | 63 74 28 76 6f 69 64 20 |nt conne|ct(void | |00001240| 2a 20 61 64 64 72 65 73 | 73 2c 20 69 6e 74 20 61 |* addres|s, int a| |00001250| 64 64 72 6c 65 6e 29 3b | 0d 09 76 69 72 74 75 61 |ddrlen);|..virtua| |00001260| 6c 20 69 6e 74 20 72 65 | 63 76 66 72 6f 6d 28 76 |l int re|cvfrom(v| |00001270| 6f 69 64 20 2a 20 62 75 | 66 66 65 72 2c 20 69 6e |oid * bu|ffer, in| |00001280| 74 20 62 75 66 6c 65 6e | 2c 20 69 6e 74 20 66 6c |t buflen|, int fl| |00001290| 61 67 73 2c 20 76 6f 69 | 64 20 2a 20 66 72 6f 6d |ags, voi|d * from| |000012a0| 2c 20 69 6e 74 20 2a 20 | 66 72 6f 6d 6c 65 6e 29 |, int * |fromlen)| |000012b0| 3b 0d 09 76 69 72 74 75 | 61 6c 20 69 6e 74 20 73 |;..virtu|al int s| |000012c0| 65 6e 64 74 6f 28 76 6f | 69 64 20 2a 20 62 75 66 |endto(vo|id * buf| |000012d0| 66 65 72 2c 20 69 6e 74 | 20 62 75 66 6c 65 6e 2c |fer, int| buflen,| |000012e0| 20 69 6e 74 20 66 6c 61 | 67 73 2c 20 76 6f 69 64 | int fla|gs, void| |000012f0| 20 2a 20 74 6f 2c 20 69 | 6e 74 20 74 6f 6c 65 6e | * to, i|nt tolen| |00001300| 29 3b 0d 09 0d 09 76 69 | 72 74 75 61 6c 20 09 09 |);....vi|rtual ..| |00001310| 7e 55 6e 69 78 44 67 72 | 61 6d 53 6f 63 6b 65 74 |~UnixDgr|amSocket| |00001320| 28 29 3b 0d 7d 3b 0d 0d | 73 74 72 75 63 74 20 55 |();.};..|struct U| |00001330| 6e 69 78 53 6f 63 6b 65 | 74 49 44 20 7b 0d 09 55 |nixSocke|tID {..U| |00001340| 6e 69 78 43 68 61 6e 6e | 65 6c 09 2a 09 09 09 63 |nixChann|el.*...c| |00001350| 68 61 6e 3b 0d 09 0d 09 | 41 64 64 72 42 6c 6f 63 |han;....|AddrBloc| |00001360| 6b 09 09 09 09 6d 61 63 | 68 69 6e 65 3b 0d 09 50 |k....mac|hine;..P| |00001370| 72 6f 63 65 73 73 53 65 | 72 69 61 6c 4e 75 6d 62 |rocessSe|rialNumb| |00001380| 65 72 09 70 72 6f 63 65 | 73 73 3b 0d 09 0d 09 09 |er.proce|ss;.....| |00001390| 09 09 55 6e 69 78 53 6f | 63 6b 65 74 49 44 28 29 |..UnixSo|cketID()| |000013a0| 09 09 09 09 09 09 09 09 | 09 09 7b 7d 0d 09 09 09 |........|..{}....| |000013b0| 09 55 6e 69 78 53 6f 63 | 6b 65 74 49 44 28 55 6e |.UnixSoc|ketID(Un| |000013c0| 69 78 43 68 61 6e 6e 65 | 6c 20 2a 20 63 68 29 3b |ixChanne|l * ch);| |000013d0| 0d 09 42 6f 6f 6c 65 61 | 6e 09 56 61 6c 69 64 61 |..Boolea|n.Valida| |000013e0| 74 65 28 29 3b 0d 7d 3b | 0d 0d 2f 2a 2a 2a 2a 2a |te();.};|../*****| |000013f0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00001400| 2a 20 55 6e 69 78 53 6f | 63 6b 65 74 41 64 64 72 |* UnixSo|cketAddr| |00001410| 20 6d 65 6d 62 65 72 73 | 20 2a 2a 2a 2a 2a 2a 2a | members| *******| |00001420| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00001430| 2f 0d 0d 69 6e 6c 69 6e | 65 20 55 6e 69 78 53 6f |/..inlin|e UnixSo| |00001440| 63 6b 65 74 41 64 64 72 | 3a 3a 55 6e 69 78 53 6f |cketAddr|::UnixSo| |00001450| 63 6b 65 74 41 64 64 72 | 28 29 20 0d 09 3a 20 76 |cketAddr|() ..: v| |00001460| 61 6c 69 64 28 66 61 6c | 73 65 29 2c 20 6f 77 6e |alid(fal|se), own| |00001470| 65 64 28 74 72 75 65 29 | 09 09 09 0d 7b 0d 7d 0d |ed(true)|....{.}.| |00001480| 0d 69 6e 6c 69 6e 65 20 | 55 6e 69 78 53 6f 63 6b |.inline |UnixSock| |00001490| 65 74 41 64 64 72 3a 3a | 55 6e 69 78 53 6f 63 6b |etAddr::|UnixSock| |000014a0| 65 74 41 64 64 72 28 54 | 46 69 6c 65 53 70 65 63 |etAddr(T|FileSpec| |000014b0| 20 73 70 65 63 29 20 0d | 09 3a 20 54 46 69 6c 65 | spec) .|.: TFile| |000014c0| 53 70 65 63 28 73 70 65 | 63 29 2c 20 76 61 6c 69 |Spec(spe|c), vali| |000014d0| 64 28 66 61 6c 73 65 29 | 2c 20 6f 77 6e 65 64 28 |d(false)|, owned(| |000014e0| 74 72 75 65 29 09 09 09 | 0d 7b 0d 7d 0d 0d 2f 2a |true)...|.{.}../*| |000014f0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00001500| 2a 2a 2a 2a 2a 2a 2a 20 | 55 6e 69 78 53 6f 63 6b |******* |UnixSock| |00001510| 65 74 20 6d 65 6d 62 65 | 72 73 20 2a 2a 2a 2a 2a |et membe|rs *****| |00001520| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00001530| 2a 2a 2a 2f 0d 0d 73 74 | 61 74 69 63 20 55 6e 69 |***/..st|atic Uni| |00001540| 78 53 6f 63 6b 65 74 41 | 64 64 72 20 2a 20 43 61 |xSocketA|ddr * Ca| |00001550| 6e 6f 6e 69 7a 65 4e 61 | 6d 65 28 76 6f 69 64 20 |nonizeNa|me(void | |00001560| 2a 20 6e 61 6d 65 2c 20 | 69 6e 74 20 6c 65 6e 29 |* name, |int len)| |00001570| 3b 0d 73 74 61 74 69 63 | 20 76 6f 69 64 20 09 09 |;.static| void ..| |00001580| 09 09 55 6e 63 61 6e 6f | 6e 69 7a 65 4e 61 6d 65 |..Uncano|nizeName| |00001590| 28 55 6e 69 78 53 6f 63 | 6b 65 74 41 64 64 72 20 |(UnixSoc|ketAddr | |000015a0| 26 20 6e 61 6d 65 2c 20 | 76 6f 69 64 20 2a 20 61 |& name, |void * a| |000015b0| 64 64 72 2c 20 69 6e 74 | 20 2a 20 61 64 64 72 6c |ddr, int| * addrl| |000015c0| 65 6e 29 3b 0d 73 74 61 | 74 69 63 20 55 6e 69 78 |en);.sta|tic Unix| |000015d0| 43 68 61 6e 6e 65 6c 20 | 2a 20 09 4c 6f 6f 6b 75 |Channel |* .Looku| |000015e0| 70 4e 61 6d 65 28 55 6e | 69 78 53 6f 63 6b 65 74 |pName(Un|ixSocket| |000015f0| 41 64 64 72 20 6e 61 6d | 65 29 3b 0d 0d 55 6e 69 |Addr nam|e);..Uni| |00001600| 78 53 6f 63 6b 65 74 3a | 3a 55 6e 69 78 53 6f 63 |xSocket:|:UnixSoc| |00001610| 6b 65 74 28 73 68 6f 72 | 74 20 70 72 6f 74 29 0d |ket(shor|t prot).| |00001620| 7b 0d 09 47 55 53 49 5f | 65 72 72 6f 72 28 30 29 |{..GUSI_|error(0)| |00001630| 3b 0d 09 0d 09 72 65 61 | 64 42 75 66 53 69 7a 65 |;....rea|dBufSize| |00001640| 09 09 3d 09 44 45 46 41 | 55 4c 54 5f 42 55 46 46 |..=.DEFA|ULT_BUFF| |00001650| 45 52 5f 53 49 5a 45 3b | 0d 09 73 74 61 74 75 73 |ER_SIZE;|..status| |00001660| 09 09 09 3d 09 53 4f 43 | 4b 5f 53 54 41 54 55 53 |...=.SOC|K_STATUS| |00001670| 5f 55 53 45 44 3b 0d 09 | 73 74 61 74 65 09 09 09 |_USED;..|state...| |00001680| 09 3d 09 53 4f 43 4b 5f | 53 54 41 54 45 5f 55 4e |.=.SOCK_|STATE_UN| |00001690| 43 4f 4e 4e 45 43 54 45 | 44 3b 0d 09 6e 6f 6e 62 |CONNECTE|D;..nonb| |000016a0| 6c 6f 63 6b 69 6e 67 09 | 09 3d 09 66 61 6c 73 65 |locking.|.=.false| |000016b0| 3b 0d 09 70 72 6f 74 6f | 63 6f 6c 09 09 09 3d 09 |;..proto|col...=.| |000016c0| 70 72 6f 74 3b 0d 09 72 | 65 61 64 50 6f 73 09 09 |prot;..r|eadPos..| |000016d0| 09 3d 09 30 3b 0d 09 76 | 61 6c 69 64 42 79 74 65 |.=.0;..v|alidByte| |000016e0| 73 09 09 3d 09 30 3b 0d | 09 63 75 72 4c 69 73 74 |s..=.0;.|.curList| |000016f0| 65 6e 65 72 09 09 3d 09 | 30 3b 0d 09 6d 61 78 4c |ener..=.|0;..maxL| |00001700| 69 73 74 65 6e 65 72 09 | 09 3d 09 30 3b 0d 09 66 |istener.|.=.0;..f| |00001710| 69 72 73 74 4c 69 73 74 | 65 6e 65 72 09 3d 09 6e |irstList|ener.=.n| |00001720| 69 6c 3b 0d 09 6c 61 73 | 74 4c 69 73 74 65 6e 65 |il;..las|tListene| |00001730| 72 09 3d 09 6e 69 6c 3b | 0d 09 63 68 61 6e 09 09 |r.=.nil;|..chan..| |00001740| 09 09 3d 09 6e 69 6c 3b | 0d 09 70 65 65 72 09 09 |..=.nil;|..peer..| |00001750| 09 09 3d 09 6e 69 6c 3b | 0d 09 72 65 61 64 42 75 |..=.nil;|..readBu| |00001760| 66 09 09 09 3d 09 4e 65 | 77 50 74 72 28 72 65 61 |f...=.Ne|wPtr(rea| |00001770| 64 42 75 66 53 69 7a 65 | 29 3b 0d 09 0d 09 69 66 |dBufSize|);....if| |00001780| 20 28 21 72 65 61 64 42 | 75 66 29 0d 09 09 47 55 | (!readB|uf)...GU| |00001790| 53 49 5f 65 72 72 6f 72 | 28 45 4e 4f 4d 45 4d 29 |SI_error|(ENOMEM)| |000017a0| 3b 0d 7d 0d 0d 55 6e 69 | 78 53 6f 63 6b 65 74 3a |;.}..Uni|xSocket:| |000017b0| 3a 7e 55 6e 69 78 53 6f | 63 6b 65 74 28 29 0d 7b |:~UnixSo|cket().{| |000017c0| 0d 09 69 66 20 28 72 65 | 61 64 42 75 66 29 0d 09 |..if (re|adBuf)..| |000017d0| 09 44 69 73 70 6f 73 50 | 74 72 28 72 65 61 64 42 |.DisposP|tr(readB| |000017e0| 75 66 29 3b 0d 09 0d 09 | 69 66 20 28 70 72 6f 74 |uf);....|if (prot| |000017f0| 6f 63 6f 6c 20 3d 3d 20 | 53 4f 43 4b 5f 53 54 52 |ocol == |SOCK_STR| |00001800| 45 41 4d 29 0d 09 09 69 | 66 20 28 70 65 65 72 29 |EAM)...i|f (peer)| |00001810| 0d 09 09 09 70 65 65 72 | 2d 3e 44 69 73 63 6f 6e |....peer|->Discon| |00001820| 6e 65 63 74 28 29 3b 0d | 09 09 65 6c 73 65 20 0d |nect();.|..else .| |00001830| 09 09 09 77 68 69 6c 65 | 20 28 66 69 72 73 74 4c |...while| (firstL| |00001840| 69 73 74 65 6e 65 72 29 | 20 7b 0d 09 09 09 09 66 |istener)| {.....f| |00001850| 69 72 73 74 4c 69 73 74 | 65 6e 65 72 2d 3e 44 69 |irstList|ener->Di| |00001860| 73 63 6f 6e 6e 65 63 74 | 28 29 3b 0d 09 09 09 09 |sconnect|();.....| |00001870| 0d 09 09 09 09 66 69 72 | 73 74 4c 69 73 74 65 6e |.....fir|stListen| |00001880| 65 72 20 3d 20 66 69 72 | 73 74 4c 69 73 74 65 6e |er = fir|stListen| |00001890| 65 72 2d 3e 6e 65 78 74 | 4c 69 73 74 65 6e 65 72 |er->next|Listener| |000018a0| 3b 0d 09 09 09 7d 0d 09 | 09 0d 09 69 66 20 28 63 |;....}..|...if (c| |000018b0| 68 61 6e 29 0d 09 09 64 | 65 6c 65 74 65 20 63 68 |han)...d|elete ch| |000018c0| 61 6e 3b 0d 7d 0d 0d 76 | 6f 69 64 20 55 6e 69 78 |an;.}..v|oid Unix| |000018d0| 53 6f 63 6b 65 74 3a 3a | 64 65 66 61 75 6c 74 62 |Socket::|defaultb| |000018e0| 69 6e 64 28 29 0d 7b 0d | 09 73 74 72 75 63 74 20 |ind().{.|.struct | |000018f0| 73 6f 63 6b 61 64 64 72 | 5f 75 6e 09 61 64 64 72 |sockaddr|_un.addr| |00001900| 3b 0d 09 0d 09 61 64 64 | 72 2e 73 75 6e 5f 66 61 |;....add|r.sun_fa| |00001910| 6d 69 6c 79 09 3d 09 41 | 46 5f 55 4e 49 58 3b 0d |mily.=.A|F_UNIX;.| |00001920| 09 74 6d 70 6e 61 6d 28 | 61 64 64 72 2e 73 75 6e |.tmpnam(|addr.sun| |00001930| 5f 70 61 74 68 29 3b 0d | 09 0d 09 62 69 6e 64 28 |_path);.|...bind(| |00001940| 26 61 64 64 72 2c 20 73 | 74 72 6c 65 6e 28 61 64 |&addr, s|trlen(ad| |00001950| 64 72 2e 73 75 6e 5f 70 | 61 74 68 29 2b 32 29 3b |dr.sun_p|ath)+2);| |00001960| 0d 7d 0d 0d 69 6e 74 20 | 55 6e 69 78 53 6f 63 6b |.}..int |UnixSock| |00001970| 65 74 3a 3a 66 63 6e 74 | 6c 28 75 6e 73 69 67 6e |et::fcnt|l(unsign| |00001980| 65 64 20 69 6e 74 20 63 | 6d 64 2c 20 69 6e 74 20 |ed int c|md, int | |00001990| 61 72 67 29 0d 7b 0d 09 | 73 77 69 74 63 68 20 28 |arg).{..|switch (| |000019a0| 63 6d 64 29 09 7b 0d 09 | 63 61 73 65 20 46 5f 47 |cmd).{..|case F_G| |000019b0| 45 54 46 4c 3a 0d 09 09 | 69 66 20 28 6e 6f 6e 62 |ETFL:...|if (nonb| |000019c0| 6c 6f 63 6b 69 6e 67 29 | 0d 09 09 09 72 65 74 75 |locking)|....retu| |000019d0| 72 6e 20 46 4e 44 45 4c | 41 59 3b 0d 09 09 65 6c |rn FNDEL|AY;...el| |000019e0| 73 65 0d 09 09 09 72 65 | 74 75 72 6e 20 30 3b 0d |se....re|turn 0;.| |000019f0| 09 63 61 73 65 20 46 5f | 53 45 54 46 4c 3a 0d 09 |.case F_|SETFL:..| |00001a00| 09 69 66 20 28 61 72 67 | 20 26 20 46 4e 44 45 4c |.if (arg| & FNDEL| |00001a10| 41 59 29 0d 09 09 09 6e | 6f 6e 62 6c 6f 63 6b 69 |AY)....n|onblocki| |00001a20| 6e 67 20 3d 20 74 72 75 | 65 3b 0d 09 09 65 6c 73 |ng = tru|e;...els| |00001a30| 65 0d 09 09 09 6e 6f 6e | 62 6c 6f 63 6b 69 6e 67 |e....non|blocking| |00001a40| 20 3d 20 66 61 6c 73 65 | 3b 0d 09 09 09 0d 09 09 | = false|;.......| |00001a50| 72 65 74 75 72 6e 20 30 | 3b 0d 09 64 65 66 61 75 |return 0|;..defau| |00001a60| 6c 74 3a 0d 09 09 72 65 | 74 75 72 6e 20 47 55 53 |lt:...re|turn GUS| |00001a70| 49 5f 65 72 72 6f 72 28 | 45 4f 50 4e 4f 54 53 55 |I_error(|EOPNOTSU| |00001a80| 50 50 29 3b 0d 09 7d 0d | 7d 0d 0d 69 6e 74 20 55 |PP);..}.|}..int U| |00001a90| 6e 69 78 53 6f 63 6b 65 | 74 3a 3a 69 6f 63 74 6c |nixSocke|t::ioctl| |00001aa0| 28 75 6e 73 69 67 6e 65 | 64 20 69 6e 74 20 72 65 |(unsigne|d int re| |00001ab0| 71 75 65 73 74 2c 20 76 | 6f 69 64 20 2a 61 72 67 |quest, v|oid *arg| |00001ac0| 70 29 0d 7b 0d 09 73 77 | 69 74 63 68 20 28 72 65 |p).{..sw|itch (re| |00001ad0| 71 75 65 73 74 29 09 7b | 0d 09 63 61 73 65 20 46 |quest).{|..case F| |00001ae0| 49 4f 4e 42 49 4f 3a 0d | 09 09 6e 6f 6e 62 6c 6f |IONBIO:.|..nonblo| |00001af0| 63 6b 69 6e 67 09 3d 09 | 28 42 6f 6f 6c 65 61 6e |cking.=.|(Boolean| |00001b00| 29 20 2a 28 6c 6f 6e 67 | 20 2a 29 20 61 72 67 70 |) *(long| *) argp| |00001b10| 3b 0d 09 09 0d 09 09 72 | 65 74 75 72 6e 20 30 3b |;......r|eturn 0;| |00001b20| 0d 09 63 61 73 65 20 46 | 49 4f 4e 52 45 41 44 3a |..case F|IONREAD:| |00001b30| 0d 09 09 69 66 20 28 63 | 68 61 6e 29 0d 09 09 09 |...if (c|han)....| |00001b40| 2a 28 6c 6f 6e 67 20 2a | 29 20 61 72 67 70 20 3d |*(long *|) argp =| |00001b50| 20 63 68 61 6e 2d 3e 52 | 65 61 64 41 76 61 69 6c | chan->R|eadAvail| |00001b60| 28 29 3b 0d 09 09 65 6c | 73 65 0d 09 09 09 2a 28 |();...el|se....*(| |00001b70| 6c 6f 6e 67 20 2a 29 20 | 61 72 67 70 09 3d 20 30 |long *) |argp.= 0| |00001b80| 3b 0d 0d 09 09 72 65 74 | 75 72 6e 20 30 3b 0d 09 |;....ret|urn 0;..| |00001b90| 64 65 66 61 75 6c 74 3a | 0d 09 09 72 65 74 75 72 |default:|...retur| |00001ba0| 6e 20 47 55 53 49 5f 65 | 72 72 6f 72 28 45 4f 50 |n GUSI_e|rror(EOP| |00001bb0| 4e 4f 54 53 55 50 50 29 | 3b 0d 09 7d 0d 7d 0d 0d |NOTSUPP)|;..}.}..| |00001bc0| 69 6e 74 20 55 6e 69 78 | 53 6f 63 6b 65 74 3a 3a |int Unix|Socket::| |00001bd0| 62 69 6e 64 28 76 6f 69 | 64 20 2a 73 61 5f 6e 61 |bind(voi|d *sa_na| |00001be0| 6d 65 2c 20 69 6e 74 20 | 73 61 5f 6e 61 6d 65 6c |me, int |sa_namel| |00001bf0| 65 6e 29 0d 7b 0d 09 55 | 6e 69 78 53 6f 63 6b 65 |en).{..U|nixSocke| |00001c00| 74 41 64 64 72 20 2a 09 | 61 64 64 72 3b 0d 09 0d |tAddr *.|addr;...| |00001c10| 09 69 66 20 28 63 68 61 | 6e 20 26 26 20 63 68 61 |.if (cha|n && cha| |00001c20| 6e 2d 3e 41 64 64 72 65 | 73 73 28 29 2e 76 61 6c |n->Addre|ss().val| |00001c30| 69 64 29 0d 09 09 09 72 | 65 74 75 72 6e 20 47 55 |id)....r|eturn GU| |00001c40| 53 49 5f 65 72 72 6f 72 | 28 45 49 4e 56 41 4c 29 |SI_error|(EINVAL)| |00001c50| 3b 0d 09 0d 09 61 64 64 | 72 09 3d 09 43 61 6e 6f |;....add|r.=.Cano| |00001c60| 6e 69 7a 65 4e 61 6d 65 | 28 73 61 5f 6e 61 6d 65 |nizeName|(sa_name| |00001c70| 2c 20 73 61 5f 6e 61 6d | 65 6c 65 6e 29 3b 0d 09 |, sa_nam|elen);..| |00001c80| 0d 09 69 66 20 28 21 61 | 64 64 72 29 0d 09 09 72 |..if (!a|ddr)...r| |00001c90| 65 74 75 72 6e 20 2d 31 | 3b 0d 09 0d 09 69 66 20 |eturn -1|;....if | |00001ca0| 28 4c 6f 6f 6b 75 70 4e | 61 6d 65 28 2a 61 64 64 |(LookupN|ame(*add| |00001cb0| 72 29 29 0d 09 09 72 65 | 74 75 72 6e 20 47 55 53 |r))...re|turn GUS| |00001cc0| 49 5f 65 72 72 6f 72 28 | 45 41 44 44 52 49 4e 55 |I_error(|EADDRINU| |00001cd0| 53 45 29 3b 0d 0d 09 69 | 66 20 28 21 63 68 61 6e |SE);...i|f (!chan| |00001ce0| 20 26 26 20 21 28 63 68 | 61 6e 20 3d 20 6e 65 77 | && !(ch|an = new| |00001cf0| 20 55 6e 69 78 43 68 61 | 6e 6e 65 6c 32 28 74 68 | UnixCha|nnel2(th| |00001d00| 69 73 29 29 29 0d 09 09 | 72 65 74 75 72 6e 20 47 |is)))...|return G| |00001d10| 55 53 49 5f 65 72 72 6f | 72 28 45 4e 4f 4d 45 4d |USI_erro|r(ENOMEM| |00001d20| 29 3b 0d 09 0d 09 69 66 | 20 28 21 63 68 61 6e 2d |);....if| (!chan-| |00001d30| 3e 42 69 6e 64 28 2a 61 | 64 64 72 29 29 0d 09 09 |>Bind(*a|ddr))...| |00001d40| 72 65 74 75 72 6e 20 47 | 55 53 49 5f 65 72 72 6f |return G|USI_erro| |00001d50| 72 28 45 4e 4f 4d 45 4d | 29 3b 0d 09 0d 09 72 65 |r(ENOMEM|);....re| |00001d60| 74 75 72 6e 20 30 3b 0d | 7d 0d 0d 69 6e 74 20 55 |turn 0;.|}..int U| |00001d70| 6e 69 78 53 6f 63 6b 65 | 74 3a 3a 67 65 74 73 6f |nixSocke|t::getso| |00001d80| 63 6b 6e 61 6d 65 28 76 | 6f 69 64 20 2a 6e 61 6d |ckname(v|oid *nam| |00001d90| 65 2c 20 69 6e 74 20 2a | 6e 61 6d 65 6c 65 6e 29 |e, int *|namelen)| |00001da0| 0d 7b 0d 09 55 6e 63 61 | 6e 6f 6e 69 7a 65 4e 61 |.{..Unca|nonizeNa| |00001db0| 6d 65 28 63 68 61 6e 2d | 3e 41 64 64 72 65 73 73 |me(chan-|>Address| |00001dc0| 28 29 2c 20 6e 61 6d 65 | 2c 20 6e 61 6d 65 6c 65 |(), name|, namele| |00001dd0| 6e 29 3b 0d 09 0d 09 72 | 65 74 75 72 6e 20 30 3b |n);....r|eturn 0;| |00001de0| 0d 7d 0d 0d 69 6e 74 20 | 55 6e 69 78 53 6f 63 6b |.}..int |UnixSock| |00001df0| 65 74 3a 3a 67 65 74 70 | 65 65 72 6e 61 6d 65 28 |et::getp|eername(| |00001e00| 76 6f 69 64 20 2a 6e 61 | 6d 65 2c 20 69 6e 74 20 |void *na|me, int | |00001e10| 2a 6e 61 6d 65 6c 65 6e | 29 0d 7b 0d 09 69 66 20 |*namelen|).{..if | |00001e20| 28 21 70 65 65 72 29 0d | 09 09 72 65 74 75 72 6e |(!peer).|..return| |00001e30| 20 47 55 53 49 5f 65 72 | 72 6f 72 28 45 4e 4f 54 | GUSI_er|ror(ENOT| |00001e40| 43 4f 4e 4e 29 3b 0d 09 | 09 0d 09 55 6e 63 61 6e |CONN);..|...Uncan| |00001e50| 6f 6e 69 7a 65 4e 61 6d | 65 28 70 65 65 72 2d 3e |onizeNam|e(peer->| |00001e60| 41 64 64 72 65 73 73 28 | 29 2c 20 6e 61 6d 65 2c |Address(|), name,| |00001e70| 20 6e 61 6d 65 6c 65 6e | 29 3b 0d 09 0d 09 72 65 | namelen|);....re| |00001e80| 74 75 72 6e 20 30 3b 0d | 7d 0d 0d 69 6e 74 20 55 |turn 0;.|}..int U| |00001e90| 6e 69 78 53 6f 63 6b 65 | 74 3a 3a 73 65 6c 65 63 |nixSocke|t::selec| |00001ea0| 74 28 42 6f 6f 6c 65 61 | 6e 20 2a 20 63 61 6e 52 |t(Boolea|n * canR| |00001eb0| 65 61 64 2c 20 42 6f 6f | 6c 65 61 6e 20 2a 20 63 |ead, Boo|lean * c| |00001ec0| 61 6e 57 72 69 74 65 2c | 20 42 6f 6f 6c 65 61 6e |anWrite,| Boolean| |00001ed0| 20 2a 20 65 78 63 65 70 | 74 69 6f 6e 29 0d 7b 0d | * excep|tion).{.| |00001ee0| 09 69 6e 74 09 67 6f 6f | 64 69 65 73 20 3d 20 30 |.int.goo|dies = 0| |00001ef0| 3b 0d 09 0d 09 69 66 20 | 28 63 61 6e 52 65 61 64 |;....if |(canRead| |00001f00| 29 0d 09 09 69 66 20 28 | 28 73 74 61 74 65 20 3d |)...if (|(state =| |00001f10| 3d 20 53 4f 43 4b 5f 53 | 54 41 54 45 5f 4c 49 53 |= SOCK_S|TATE_LIS| |00001f20| 5f 43 4f 4e 29 20 7c 7c | 20 28 63 68 61 6e 20 26 |_CON) ||| (chan &| |00001f30| 26 20 63 68 61 6e 2d 3e | 52 65 61 64 41 76 61 69 |& chan->|ReadAvai| |00001f40| 6c 28 29 29 29 09 7b 0d | 09 09 09 2a 63 61 6e 52 |l())).{.|...*canR| |00001f50| 65 61 64 09 3d 20 09 74 | 72 75 65 3b 0d 09 09 09 |ead.= .t|rue;....| |00001f60| 2b 2b 67 6f 6f 64 69 65 | 73 3b 0d 09 09 7d 20 65 |++goodie|s;...} e| |00001f70| 6c 73 65 0d 09 09 09 2a | 63 61 6e 52 65 61 64 09 |lse....*|canRead.| |00001f80| 3d 09 66 61 6c 73 65 3b | 0d 09 0d 09 69 66 20 28 |=.false;|....if (| |00001f90| 63 61 6e 57 72 69 74 65 | 29 0d 09 09 69 66 20 28 |canWrite|)...if (| |00001fa0| 70 65 65 72 20 26 26 20 | 70 65 65 72 2d 3e 57 72 |peer && |peer->Wr| |00001fb0| 69 74 65 41 76 61 69 6c | 28 29 29 09 7b 0d 09 09 |iteAvail|()).{...| |00001fc0| 09 2a 63 61 6e 57 72 69 | 74 65 09 3d 20 09 74 72 |.*canWri|te.= .tr| |00001fd0| 75 65 3b 0d 09 09 09 2b | 2b 67 6f 6f 64 69 65 73 |ue;....+|+goodies| |00001fe0| 3b 0d 09 09 7d 20 65 6c | 73 65 0d 09 09 09 2a 63 |;...} el|se....*c| |00001ff0| 61 6e 57 72 69 74 65 09 | 3d 09 66 61 6c 73 65 3b |anWrite.|=.false;| |00002000| 0d 09 0d 09 69 66 20 28 | 65 78 63 65 70 74 69 6f |....if (|exceptio| |00002010| 6e 29 0d 09 09 2a 65 78 | 63 65 70 74 69 6f 6e 09 |n)...*ex|ception.| |00002020| 3d 09 66 61 6c 73 65 3b | 0d 09 0d 09 72 65 74 75 |=.false;|....retu| |00002030| 72 6e 20 67 6f 6f 64 69 | 65 73 3b 0d 7d 0d 0d 69 |rn goodi|es;.}..i| |00002040| 6e 74 20 55 6e 69 78 53 | 6f 63 6b 65 74 3a 3a 73 |nt UnixS|ocket::s| |00002050| 68 75 74 64 6f 77 6e 28 | 69 6e 74 20 68 6f 77 29 |hutdown(|int how)| |00002060| 0d 7b 0d 09 69 66 20 28 | 21 63 68 61 6e 29 0d 09 |.{..if (|!chan)..| |00002070| 09 72 65 74 75 72 6e 20 | 47 55 53 49 5f 65 72 72 |.return |GUSI_err| |00002080| 6f 72 28 45 4e 4f 54 43 | 4f 4e 4e 29 3b 0d 0d 09 |or(ENOTC|ONN);...| |00002090| 63 68 61 6e 2d 3e 53 68 | 75 74 44 6f 77 6e 28 68 |chan->Sh|utDown(h| |000020a0| 6f 77 29 3b 0d 09 0d 09 | 72 65 74 75 72 6e 20 30 |ow);....|return 0| |000020b0| 3b 0d 7d 0d 0d 2f 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |;.}../**|********| |000020c0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 20 55 6e 69 78 |********|*** Unix| |000020d0| 53 74 72 65 61 6d 53 6f | 63 6b 65 74 20 6d 65 6d |StreamSo|cket mem| |000020e0| 62 65 72 73 20 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |bers ***|********| |000020f0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2f 0d 0d 55 6e 69 |********|**/..Uni| |00002100| 78 53 74 72 65 61 6d 53 | 6f 63 6b 65 74 3a 3a 55 |xStreamS|ocket::U| |00002110| 6e 69 78 53 74 72 65 61 | 6d 53 6f 63 6b 65 74 28 |nixStrea|mSocket(| |00002120| 29 0d 09 3a 09 55 6e 69 | 78 53 6f 63 6b 65 74 28 |)..:.Uni|xSocket(| |00002130| 53 4f 43 4b 5f 53 54 52 | 45 41 4d 29 0d 7b 0d 7d |SOCK_STR|EAM).{.}| |00002140| 0d 0d 55 6e 69 78 53 74 | 72 65 61 6d 53 6f 63 6b |..UnixSt|reamSock| |00002150| 65 74 3a 3a 7e 55 6e 69 | 78 53 74 72 65 61 6d 53 |et::~Uni|xStreamS| |00002160| 6f 63 6b 65 74 28 29 0d | 7b 0d 7d 0d 0d 69 6e 74 |ocket().|{.}..int| |00002170| 20 55 6e 69 78 53 74 72 | 65 61 6d 53 6f 63 6b 65 | UnixStr|eamSocke| |00002180| 74 3a 3a 6c 69 73 74 65 | 6e 28 69 6e 74 20 71 6c |t::liste|n(int ql| |00002190| 65 6e 29 0d 7b 0d 09 69 | 66 20 28 73 74 61 74 65 |en).{..i|f (state| |000021a0| 20 21 3d 20 53 4f 43 4b | 5f 53 54 41 54 45 5f 55 | != SOCK|_STATE_U| |000021b0| 4e 43 4f 4e 4e 45 43 54 | 45 44 29 0d 09 09 72 65 |NCONNECT|ED)...re| |000021c0| 74 75 72 6e 20 47 55 53 | 49 5f 65 72 72 6f 72 28 |turn GUS|I_error(| |000021d0| 45 49 53 43 4f 4e 4e 29 | 3b 0d 09 09 0d 09 73 74 |EISCONN)|;.....st| |000021e0| 61 74 65 09 09 09 3d 09 | 53 4f 43 4b 5f 53 54 41 |ate...=.|SOCK_STA| |000021f0| 54 45 5f 4c 49 53 54 45 | 4e 49 4e 47 3b 0d 09 6d |TE_LISTE|NING;..m| |00002200| 61 78 4c 69 73 74 65 6e | 65 72 09 3d 09 71 6c 65 |axListen|er.=.qle| |00002210| 6e 3b 0d 09 0d 09 72 65 | 74 75 72 6e 20 30 3b 0d |n;....re|turn 0;.| |00002220| 7d 0d 0d 69 6e 74 20 55 | 6e 69 78 53 74 72 65 61 |}..int U|nixStrea| |00002230| 6d 53 6f 63 6b 65 74 3a | 3a 63 6f 6e 6e 65 63 74 |mSocket:|:connect| |00002240| 28 76 6f 69 64 20 2a 73 | 61 5f 6e 61 6d 65 2c 20 |(void *s|a_name, | |00002250| 69 6e 74 20 73 61 5f 6e | 61 6d 65 6c 65 6e 29 0d |int sa_n|amelen).| |00002260| 7b 0d 09 55 6e 69 78 53 | 6f 63 6b 65 74 41 64 64 |{..UnixS|ocketAdd| |00002270| 72 20 2a 09 61 64 64 72 | 3b 0d 09 55 6e 69 78 43 |r *.addr|;..UnixC| |00002280| 68 61 6e 6e 65 6c 20 20 | 20 20 2a 09 6f 74 68 65 |hannel | *.othe| |00002290| 72 3b 0d 09 0d 09 69 66 | 20 28 70 65 65 72 29 0d |r;....if| (peer).| |000022a0| 09 09 72 65 74 75 72 6e | 20 47 55 53 49 5f 65 72 |..return| GUSI_er| |000022b0| 72 6f 72 28 45 49 53 43 | 4f 4e 4e 29 3b 0d 09 0d |ror(EISC|ONN);...| |000022c0| 09 61 64 64 72 09 3d 09 | 43 61 6e 6f 6e 69 7a 65 |.addr.=.|Canonize| |000022d0| 4e 61 6d 65 28 73 61 5f | 6e 61 6d 65 2c 20 73 61 |Name(sa_|name, sa| |000022e0| 5f 6e 61 6d 65 6c 65 6e | 29 3b 0d 09 0d 09 69 66 |_namelen|);....if| |000022f0| 20 28 21 61 64 64 72 29 | 0d 09 09 72 65 74 75 72 | (!addr)|...retur| |00002300| 6e 20 2d 31 3b 0d 09 0d | 09 6f 74 68 65 72 20 3d |n -1;...|.other =| |00002310| 20 4c 6f 6f 6b 75 70 4e | 61 6d 65 28 2a 61 64 64 | LookupN|ame(*add| |00002320| 72 29 3b 0d 09 0d 09 69 | 66 20 28 21 6f 74 68 65 |r);....i|f (!othe| |00002330| 72 29 0d 09 09 72 65 74 | 75 72 6e 20 47 55 53 49 |r)...ret|urn GUSI| |00002340| 5f 65 72 72 6f 72 28 45 | 41 44 44 52 4e 4f 54 41 |_error(E|ADDRNOTA| |00002350| 56 41 49 4c 29 3b 0d 0d | 09 69 66 20 28 21 63 68 |VAIL);..|.if (!ch| |00002360| 61 6e 20 26 26 20 21 28 | 63 68 61 6e 20 3d 20 6e |an && !(|chan = n| |00002370| 65 77 20 55 6e 69 78 43 | 68 61 6e 6e 65 6c 32 28 |ew UnixC|hannel2(| |00002380| 74 68 69 73 29 29 29 0d | 09 09 72 65 74 75 72 6e |this))).|..return| |00002390| 20 47 55 53 49 5f 65 72 | 72 6f 72 28 45 4e 4f 4d | GUSI_er|ror(ENOM| |000023a0| 45 4d 29 3b 0d 09 0d 09 | 69 66 20 28 21 63 68 61 |EM);....|if (!cha| |000023b0| 6e 2d 3e 41 64 64 72 65 | 73 73 28 29 2e 76 61 6c |n->Addre|ss().val| |000023c0| 69 64 29 0d 09 09 64 65 | 66 61 75 6c 74 62 69 6e |id)...de|faultbin| |000023d0| 64 28 29 3b 0d 09 0d 09 | 69 66 20 28 21 6f 74 68 |d();....|if (!oth| |000023e0| 65 72 2d 3e 43 6f 6e 6e | 65 63 74 28 63 68 61 6e |er->Conn|ect(chan| |000023f0| 29 29 0d 09 09 72 65 74 | 75 72 6e 20 47 55 53 49 |))...ret|urn GUSI| |00002400| 5f 65 72 72 6f 72 28 45 | 43 4f 4e 4e 52 45 46 55 |_error(E|CONNREFU| |00002410| 53 45 44 29 3b 0d 09 09 | 0d 09 73 74 61 74 65 09 |SED);...|..state.| |00002420| 3d 09 53 4f 43 4b 5f 53 | 54 41 54 45 5f 43 4f 4e |=.SOCK_S|TATE_CON| |00002430| 4e 45 43 54 49 4e 47 3b | 0d 09 0d 09 69 66 20 28 |NECTING;|....if (| |00002440| 6e 6f 6e 62 6c 6f 63 6b | 69 6e 67 29 0d 09 09 72 |nonblock|ing)...r| |00002450| 65 74 75 72 6e 20 47 55 | 53 49 5f 65 72 72 6f 72 |eturn GU|SI_error| |00002460| 28 45 49 4e 50 52 4f 47 | 52 45 53 53 29 3b 0d 09 |(EINPROG|RESS);..| |00002470| 09 0d 09 53 41 46 45 53 | 50 49 4e 28 73 74 61 74 |...SAFES|PIN(stat| |00002480| 65 20 3d 3d 20 53 4f 43 | 4b 5f 53 54 41 54 45 5f |e == SOC|K_STATE_| |00002490| 43 4f 4e 4e 45 43 54 49 | 4e 47 2c 20 53 50 5f 4d |CONNECTI|NG, SP_M| |000024a0| 49 53 43 2c 20 30 29 3b | 0d 09 0d 09 69 66 20 28 |ISC, 0);|....if (| |000024b0| 73 74 61 74 65 20 3d 3d | 20 53 4f 43 4b 5f 53 54 |state ==| SOCK_ST| |000024c0| 41 54 45 5f 43 4f 4e 4e | 45 43 54 45 44 29 0d 09 |ATE_CONN|ECTED)..| |000024d0| 09 72 65 74 75 72 6e 20 | 30 3b 0d 09 65 6c 73 65 |.return |0;..else| |000024e0| 20 69 66 20 28 21 65 72 | 72 6e 6f 29 0d 09 09 72 | if (!er|rno)...r| |000024f0| 65 74 75 72 6e 20 47 55 | 53 49 5f 65 72 72 6f 72 |eturn GU|SI_error| |00002500| 28 45 43 4f 4e 4e 52 45 | 46 55 53 45 44 29 3b 0d |(ECONNRE|FUSED);.| |00002510| 09 09 0d 09 2f 2f 20 55 | 73 65 72 20 61 62 6f 72 |....// U|ser abor| |00002520| 74 2c 20 61 20 74 72 69 | 63 6b 79 20 73 69 74 75 |t, a tri|cky situ| |00002530| 61 74 69 6f 6e 2e 20 57 | 68 61 74 20 77 65 20 64 |ation. W|hat we d| |00002540| 6f 20 64 65 70 65 6e 64 | 73 20 6f 6e 20 74 68 65 |o depend|s on the| |00002550| 20 70 65 65 72 20 63 68 | 61 6e 6e 65 6c 0d 09 2f | peer ch|annel../| |00002560| 2f 20 76 65 72 73 69 6f | 6e 2e 0d 09 0d 09 69 66 |/ versio|n.....if| |00002570| 20 28 6f 74 68 65 72 2d | 3e 56 65 72 73 69 6f 6e | (other-|>Version| |00002580| 28 29 20 3e 3d 20 63 68 | 61 6e 6e 65 6c 53 75 70 |() >= ch|annelSup| |00002590| 70 6f 72 74 73 43 6f 6e | 6e 41 62 6f 72 74 29 09 |portsCon|nAbort).| |000025a0| 2f 2f 20 54 68 65 20 6e | 65 77 20 77 61 79 0d 09 |// The n|ew way..| |000025b0| 09 28 28 55 6e 69 78 43 | 68 61 6e 6e 65 6c 32 20 |.((UnixC|hannel2 | |000025c0| 2a 29 20 6f 74 68 65 72 | 29 2d 3e 41 62 6f 72 74 |*) other|)->Abort| |000025d0| 43 6f 6e 6e 65 63 74 28 | 63 68 61 6e 29 3b 09 2f |Connect(|chan);./| |000025e0| 2f 20 54 68 69 73 20 74 | 79 70 65 20 63 61 73 74 |/ This t|ype cast| |000025f0| 20 69 73 20 73 61 66 65 | 0d 09 65 6c 73 65 09 09 | is safe|..else..| |00002600| 09 09 09 09 09 09 09 09 | 09 09 09 09 09 09 2f 2f |........|......//| |00002610| 20 54 68 65 20 6f 6c 64 | 20 77 61 79 0d 09 09 28 | The old| way...(| |00002620| 28 55 6e 69 78 43 68 61 | 6e 6e 65 6c 32 20 2a 29 |(UnixCha|nnel2 *)| |00002630| 20 63 68 61 6e 29 2d 3e | 4f 72 70 68 61 6e 28 29 | chan)->|Orphan()| |00002640| 3b 09 09 09 09 09 2f 2f | 20 54 68 69 73 20 74 79 |;.....//| This ty| |00002650| 70 65 20 63 61 73 74 20 | 69 73 20 73 61 66 65 09 |pe cast |is safe.| |00002660| 09 09 0d 09 0d 09 72 65 | 74 75 72 6e 20 2d 31 3b |......re|turn -1;| |00002670| 0d 7d 0d 0d 53 6f 63 6b | 65 74 20 2a 20 55 6e 69 |.}..Sock|et * Uni| |00002680| 78 53 74 72 65 61 6d 53 | 6f 63 6b 65 74 3a 3a 61 |xStreamS|ocket::a| |00002690| 63 63 65 70 74 28 76 6f | 69 64 20 2a 20 61 64 64 |ccept(vo|id * add| |000026a0| 72 65 73 73 2c 20 69 6e | 74 20 2a 20 61 64 64 72 |ress, in|t * addr| |000026b0| 6c 65 6e 29 0d 7b 0d 09 | 55 6e 69 78 53 74 72 65 |len).{..|UnixStre| |000026c0| 61 6d 53 6f 63 6b 65 74 | 20 2a 09 6e 65 77 73 6f |amSocket| *.newso| |000026d0| 63 6b 3b 0d 09 0d 09 69 | 66 20 28 73 74 61 74 65 |ck;....i|f (state| |000026e0| 20 21 3d 20 53 4f 43 4b | 5f 53 54 41 54 45 5f 4c | != SOCK|_STATE_L| |000026f0| 49 53 54 45 4e 49 4e 47 | 20 26 26 20 73 74 61 74 |ISTENING| && stat| |00002700| 65 20 21 3d 20 53 4f 43 | 4b 5f 53 54 41 54 45 5f |e != SOC|K_STATE_| |00002710| 4c 49 53 5f 43 4f 4e 29 | 0d 09 09 72 65 74 75 72 |LIS_CON)|...retur| |00002720| 6e 20 28 53 6f 63 6b 65 | 74 20 2a 29 20 47 55 53 |n (Socke|t *) GUS| |00002730| 49 5f 65 72 72 6f 72 5f | 6e 69 6c 28 45 4e 4f 54 |I_error_|nil(ENOT| |00002740| 43 4f 4e 4e 29 3b 0d 0d | 72 65 73 74 61 72 74 3a |CONN);..|restart:| |00002750| 09 0d 09 69 66 20 28 21 | 63 75 72 4c 69 73 74 65 |...if (!|curListe| |00002760| 6e 65 72 29 0d 09 09 69 | 66 20 28 6e 6f 6e 62 6c |ner)...i|f (nonbl| |00002770| 6f 63 6b 69 6e 67 29 0d | 09 09 09 72 65 74 75 72 |ocking).|...retur| |00002780| 6e 20 28 53 6f 63 6b 65 | 74 20 2a 29 20 47 55 53 |n (Socke|t *) GUS| |00002790| 49 5f 65 72 72 6f 72 5f | 6e 69 6c 28 45 57 4f 55 |I_error_|nil(EWOU| |000027a0| 4c 44 42 4c 4f 43 4b 29 | 3b 0d 09 09 65 6c 73 65 |LDBLOCK)|;...else| |000027b0| 0d 09 09 09 53 50 49 4e | 50 28 73 74 61 74 65 20 |....SPIN|P(state | |000027c0| 3d 3d 20 53 4f 43 4b 5f | 53 54 41 54 45 5f 4c 49 |== SOCK_|STATE_LI| |000027d0| 53 54 45 4e 49 4e 47 2c | 20 53 50 5f 4d 49 53 43 |STENING,| SP_MISC| |000027e0| 2c 20 30 29 3b 0d 09 09 | 09 0d 09 69 66 20 28 21 |, 0);...|...if (!| |000027f0| 63 75 72 4c 69 73 74 65 | 6e 65 72 29 0d 09 09 09 |curListe|ner)....| |00002800| 72 65 74 75 72 6e 20 28 | 53 6f 63 6b 65 74 20 2a |return (|Socket *| |00002810| 29 20 47 55 53 49 5f 65 | 72 72 6f 72 5f 6e 69 6c |) GUSI_e|rror_nil| |00002820| 28 45 46 41 55 4c 54 29 | 3b 09 09 09 09 09 2f 2f |(EFAULT)|;.....//| |00002830| 20 49 20 2a 72 65 61 6c | 6c 79 2a 20 68 6f 70 65 | I *real|ly* hope| |00002840| 20 74 68 69 73 20 77 6f | 6e 27 74 20 68 61 70 70 | this wo|n't happ| |00002850| 65 6e 20 0d 0d 09 6e 65 | 77 73 6f 63 6b 09 3d 09 |en ...ne|wsock.=.| |00002860| 6e 65 77 20 55 6e 69 78 | 53 74 72 65 61 6d 53 6f |new Unix|StreamSo| |00002870| 63 6b 65 74 3b 0d 09 0d | 09 69 66 20 28 21 6e 65 |cket;...|.if (!ne| |00002880| 77 73 6f 63 6b 29 0d 09 | 09 72 65 74 75 72 6e 20 |wsock)..|.return | |00002890| 28 53 6f 63 6b 65 74 20 | 2a 29 20 47 55 53 49 5f |(Socket |*) GUSI_| |000028a0| 65 72 72 6f 72 5f 6e 69 | 6c 28 45 4e 4f 4d 45 4d |error_ni|l(ENOMEM| |000028b0| 29 3b 0d 09 0d 09 6e 65 | 77 73 6f 63 6b 2d 3e 73 |);....ne|wsock->s| |000028c0| 74 61 74 65 09 09 09 3d | 09 53 4f 43 4b 5f 53 54 |tate...=|.SOCK_ST| |000028d0| 41 54 45 5f 43 4f 4e 4e | 45 43 54 45 44 3b 0d 09 |ATE_CONN|ECTED;..| |000028e0| 6e 65 77 73 6f 63 6b 2d | 3e 70 65 65 72 09 09 09 |newsock-|>peer...| |000028f0| 3d 09 66 69 72 73 74 4c | 69 73 74 65 6e 65 72 3b |=.firstL|istener;| |00002900| 0d 09 6e 65 77 73 6f 63 | 6b 2d 3e 63 68 61 6e 09 |..newsoc|k->chan.| |00002910| 09 09 3d 09 6e 65 77 20 | 55 6e 69 78 43 68 61 6e |..=.new |UnixChan| |00002920| 6e 65 6c 32 28 6e 65 77 | 73 6f 63 6b 29 3b 0d 09 |nel2(new|sock);..| |00002930| 0d 09 69 66 20 28 21 6e | 65 77 73 6f 63 6b 2d 3e |..if (!n|ewsock->| |00002940| 63 68 61 6e 29 09 7b 0d | 09 09 64 65 6c 65 74 65 |chan).{.|..delete| |00002950| 20 6e 65 77 73 6f 63 6b | 3b 0d 09 09 0d 09 09 72 | newsock|;......r| |00002960| 65 74 75 72 6e 20 28 53 | 6f 63 6b 65 74 20 2a 29 |eturn (S|ocket *)| |00002970| 20 47 55 53 49 5f 65 72 | 72 6f 72 5f 6e 69 6c 28 | GUSI_er|ror_nil(| |00002980| 45 4e 4f 4d 45 4d 29 3b | 0d 09 7d 0d 09 0d 09 6e |ENOMEM);|..}....n| |00002990| 65 77 73 6f 63 6b 2d 3e | 63 68 61 6e 2d 3e 41 64 |ewsock->|chan->Ad| |000029a0| 64 72 65 73 73 28 29 09 | 09 09 3d 09 63 68 61 6e |dress().|..=.chan| |000029b0| 2d 3e 41 64 64 72 65 73 | 73 28 29 3b 0d 09 6e 65 |->Addres|s();..ne| |000029c0| 77 73 6f 63 6b 2d 3e 63 | 68 61 6e 2d 3e 41 64 64 |wsock->c|han->Add| |000029d0| 72 65 73 73 28 29 2e 6f | 77 6e 65 64 09 3d 09 66 |ress().o|wned.=.f| |000029e0| 61 6c 73 65 3b 0d 09 0d | 09 66 69 72 73 74 4c 69 |alse;...|.firstLi| |000029f0| 73 74 65 6e 65 72 09 3d | 09 66 69 72 73 74 4c 69 |stener.=|.firstLi| |00002a00| 73 74 65 6e 65 72 2d 3e | 6e 65 78 74 4c 69 73 74 |stener->|nextList| |00002a10| 65 6e 65 72 3b 0d 09 0d | 09 69 66 20 28 21 66 69 |ener;...|.if (!fi| |00002a20| 72 73 74 4c 69 73 74 65 | 6e 65 72 29 0d 09 09 6c |rstListe|ner)...l| |00002a30| 61 73 74 4c 69 73 74 65 | 6e 65 72 20 3d 20 6e 69 |astListe|ner = ni| |00002a40| 6c 3b 0d 09 0d 09 69 66 | 20 28 21 2d 2d 63 75 72 |l;....if| (!--cur| |00002a50| 4c 69 73 74 65 6e 65 72 | 29 0d 09 09 73 74 61 74 |Listener|)...stat| |00002a60| 65 20 3d 20 53 4f 43 4b | 5f 53 54 41 54 45 5f 4c |e = SOCK|_STATE_L| |00002a70| 49 53 54 45 4e 49 4e 47 | 3b 0d 09 0d 09 69 66 20 |ISTENING|;....if | |00002a80| 28 6e 65 77 73 6f 63 6b | 2d 3e 70 65 65 72 2d 3e |(newsock|->peer->| |00002a90| 41 63 63 65 70 74 28 6e | 65 77 73 6f 63 6b 2d 3e |Accept(n|ewsock->| |00002aa0| 63 68 61 6e 29 20 3d 3d | 20 2d 31 29 09 7b 0d 09 |chan) ==| -1).{..| |00002ab0| 09 6e 65 77 73 6f 63 6b | 2d 3e 70 65 65 72 20 3d |.newsock|->peer =| |00002ac0| 20 6e 69 6c 3b 0d 09 09 | 0d 09 09 64 65 6c 65 74 | nil;...|...delet| |00002ad0| 65 20 6e 65 77 73 6f 63 | 6b 3b 0d 09 09 0d 09 09 |e newsoc|k;......| |00002ae0| 67 6f 74 6f 20 72 65 73 | 74 61 72 74 3b 0d 09 7d |goto res|tart;..}| |00002af0| 0d 0d 09 55 6e 63 61 6e | 6f 6e 69 7a 65 4e 61 6d |...Uncan|onizeNam| |00002b00| 65 28 6e 65 77 73 6f 63 | 6b 2d 3e 70 65 65 72 2d |e(newsoc|k->peer-| |00002b10| 3e 41 64 64 72 65 73 73 | 28 29 2c 20 61 64 64 72 |>Address|(), addr| |00002b20| 65 73 73 2c 20 61 64 64 | 72 6c 65 6e 29 3b 0d 09 |ess, add|rlen);..| |00002b30| 0d 09 72 65 74 75 72 6e | 20 6e 65 77 73 6f 63 6b |..return| newsock| |00002b40| 3b 0d 7d 0d 0d 69 6e 74 | 20 55 6e 69 78 53 74 72 |;.}..int| UnixStr| |00002b50| 65 61 6d 53 6f 63 6b 65 | 74 3a 3a 72 65 63 76 66 |eamSocke|t::recvf| |00002b60| 72 6f 6d 28 76 6f 69 64 | 20 2a 20 62 75 66 66 65 |rom(void| * buffe| |00002b70| 72 2c 20 69 6e 74 20 62 | 75 66 6c 65 6e 2c 20 69 |r, int b|uflen, i| |00002b80| 6e 74 20 66 6c 61 67 73 | 2c 20 76 6f 69 64 20 2a |nt flags|, void *| |00002b90| 20 66 72 6f 6d 2c 20 69 | 6e 74 20 2a 29 0d 7b 0d | from, i|nt *).{.| |00002ba0| 09 69 6e 74 09 09 09 09 | 61 76 61 69 6c 3b 0d 09 |.int....|avail;..| |00002bb0| 0d 09 69 66 20 28 66 6c | 61 67 73 20 7c 7c 20 66 |..if (fl|ags || f| |00002bc0| 72 6f 6d 29 0d 09 09 72 | 65 74 75 72 6e 20 47 55 |rom)...r|eturn GU| |00002bd0| 53 49 5f 65 72 72 6f 72 | 28 45 4f 50 4e 4f 54 53 |SI_error|(EOPNOTS| |00002be0| 55 50 50 29 3b 0d 09 69 | 66 20 28 21 63 68 61 6e |UPP);..i|f (!chan| |00002bf0| 20 7c 7c 20 21 70 65 65 | 72 29 0d 09 09 72 65 74 | || !pee|r)...ret| |00002c00| 75 72 6e 20 47 55 53 49 | 5f 65 72 72 6f 72 28 45 |urn GUSI|_error(E| |00002c10| 4e 4f 54 43 4f 4e 4e 29 | 3b 09 0d 09 09 0d 09 69 |NOTCONN)|;......i| |00002c20| 66 20 28 28 61 76 61 69 | 6c 20 3d 20 63 68 61 6e |f ((avai|l = chan| |00002c30| 2d 3e 52 65 61 64 41 76 | 61 69 6c 28 29 29 20 3d |->ReadAv|ail()) =| |00002c40| 3d 20 2d 31 29 0d 09 09 | 69 66 20 28 63 68 61 6e |= -1)...|if (chan| |00002c50| 2d 3e 65 72 72 6e 6f 20 | 3d 3d 20 45 53 48 55 54 |->errno |== ESHUT| |00002c60| 44 4f 57 4e 29 0d 09 09 | 09 72 65 74 75 72 6e 20 |DOWN)...|.return | |00002c70| 30 3b 0d 09 09 65 6c 73 | 65 0d 09 09 09 72 65 74 |0;...els|e....ret| |00002c80| 75 72 6e 20 47 55 53 49 | 5f 65 72 72 6f 72 28 63 |urn GUSI|_error(c| |00002c90| 68 61 6e 2d 3e 65 72 72 | 6e 6f 29 3b 0d 09 0d 09 |han->err|no);....| |00002ca0| 69 66 20 28 6e 6f 6e 62 | 6c 6f 63 6b 69 6e 67 20 |if (nonb|locking | |00002cb0| 26 26 20 21 61 76 61 69 | 6c 29 0d 09 09 72 65 74 |&& !avai|l)...ret| |00002cc0| 75 72 6e 20 47 55 53 49 | 5f 65 72 72 6f 72 28 45 |urn GUSI|_error(E| |00002cd0| 57 4f 55 4c 44 42 4c 4f | 43 4b 29 3b 0d 09 0d 09 |WOULDBLO|CK);....| |00002ce0| 65 72 72 6e 6f 09 3d 09 | 30 3b 0d 09 53 50 49 4e |errno.=.|0;..SPIN| |00002cf0| 28 21 28 61 76 61 69 6c | 20 3d 20 63 68 61 6e 2d |(!(avail| = chan-| |00002d00| 3e 52 65 61 64 28 62 75 | 66 66 65 72 2c 20 62 75 |>Read(bu|ffer, bu| |00002d10| 66 6c 65 6e 29 29 2c 20 | 53 50 5f 53 54 52 45 41 |flen)), |SP_STREA| |00002d20| 4d 5f 52 45 41 44 2c 20 | 30 29 3b 0d 09 69 66 20 |M_READ, |0);..if | |00002d30| 28 61 76 61 69 6c 20 3d | 3d 20 2d 31 20 26 26 20 |(avail =|= -1 && | |00002d40| 21 65 72 72 6e 6f 29 0d | 09 09 69 66 20 28 63 68 |!errno).|..if (ch| |00002d50| 61 6e 2d 3e 65 72 72 6e | 6f 20 3d 3d 20 45 53 48 |an->errn|o == ESH| |00002d60| 55 54 44 4f 57 4e 29 0d | 09 09 09 72 65 74 75 72 |UTDOWN).|...retur| |00002d70| 6e 20 30 3b 0d 09 09 65 | 6c 73 65 0d 09 09 09 47 |n 0;...e|lse....G| |00002d80| 55 53 49 5f 65 72 72 6f | 72 28 63 68 61 6e 2d 3e |USI_erro|r(chan->| |00002d90| 65 72 72 6e 6f 29 3b 0d | 09 09 09 0d 09 72 65 74 |errno);.|.....ret| |00002da0| 75 72 6e 20 61 76 61 69 | 6c 3b 0d 7d 0d 0d 69 6e |urn avai|l;.}..in| |00002db0| 74 20 55 6e 69 78 53 74 | 72 65 61 6d 53 6f 63 6b |t UnixSt|reamSock| |00002dc0| 65 74 3a 3a 73 65 6e 64 | 74 6f 28 76 6f 69 64 20 |et::send|to(void | |00002dd0| 2a 20 62 75 66 66 65 72 | 2c 20 69 6e 74 20 62 75 |* buffer|, int bu| |00002de0| 66 6c 65 6e 2c 20 69 6e | 74 20 66 6c 61 67 73 2c |flen, in|t flags,| |00002df0| 20 76 6f 69 64 20 2a 20 | 74 6f 2c 20 69 6e 74 29 | void * |to, int)| |00002e00| 0d 7b 0d 09 69 6e 74 20 | 09 61 76 61 69 6c 3b 0d |.{..int |.avail;.| |00002e10| 09 69 6e 74 09 64 6f 6e | 65 3b 0d 09 0d 09 69 66 |.int.don|e;....if| |00002e20| 20 28 66 6c 61 67 73 20 | 7c 7c 20 74 6f 29 0d 09 | (flags ||| to)..| |00002e30| 09 72 65 74 75 72 6e 20 | 47 55 53 49 5f 65 72 72 |.return |GUSI_err| |00002e40| 6f 72 28 45 4f 50 4e 4f | 54 53 55 50 50 29 3b 0d |or(EOPNO|TSUPP);.| |00002e50| 09 69 66 20 28 21 63 68 | 61 6e 20 7c 7c 20 21 70 |.if (!ch|an || !p| |00002e60| 65 65 72 29 0d 09 09 72 | 65 74 75 72 6e 20 47 55 |eer)...r|eturn GU| |00002e70| 53 49 5f 65 72 72 6f 72 | 28 45 4e 4f 54 43 4f 4e |SI_error|(ENOTCON| |00002e80| 4e 29 3b 09 0d 09 09 0d | 09 69 66 20 28 28 61 76 |N);.....|.if ((av| |00002e90| 61 69 6c 20 3d 20 70 65 | 65 72 2d 3e 57 72 69 74 |ail = pe|er->Writ| |00002ea0| 65 41 76 61 69 6c 28 29 | 29 20 3d 3d 20 2d 31 29 |eAvail()|) == -1)| |00002eb0| 0d 09 09 72 65 74 75 72 | 6e 20 47 55 53 49 5f 65 |...retur|n GUSI_e| |00002ec0| 72 72 6f 72 28 70 65 65 | 72 2d 3e 65 72 72 6e 6f |rror(pee|r->errno| |00002ed0| 29 3b 0d 09 0d 09 69 66 | 20 28 6e 6f 6e 62 6c 6f |);....if| (nonblo| |00002ee0| 63 6b 69 6e 67 20 26 26 | 20 21 61 76 61 69 6c 29 |cking &&| !avail)| |00002ef0| 0d 09 09 72 65 74 75 72 | 6e 20 47 55 53 49 5f 65 |...retur|n GUSI_e| |00002f00| 72 72 6f 72 28 45 57 4f | 55 4c 44 42 4c 4f 43 4b |rror(EWO|ULDBLOCK| |00002f10| 29 3b 0d 09 0d 09 66 6f | 72 20 28 0d 09 09 64 6f |);....fo|r (...do| |00002f20| 6e 65 20 3d 20 65 72 72 | 6e 6f 20 3d 20 30 3b 20 |ne = err|no = 0; | |00002f30| 0d 09 09 21 65 72 72 6e | 6f 20 26 26 20 62 75 66 |...!errn|o && buf| |00002f40| 6c 65 6e 3b 20 0d 09 09 | 62 75 66 6c 65 6e 20 2d |len; ...|buflen -| |00002f50| 3d 20 61 76 61 69 6c 2c | 20 62 75 66 66 65 72 20 |= avail,| buffer | |00002f60| 3d 20 50 74 72 28 62 75 | 66 66 65 72 29 20 2b 20 |= Ptr(bu|ffer) + | |00002f70| 61 76 61 69 6c 0d 09 29 | 09 7b 0d 09 09 53 50 49 |avail..)|.{...SPI| |00002f80| 4e 28 21 28 61 76 61 69 | 6c 20 3d 20 70 65 65 72 |N(!(avai|l = peer| |00002f90| 2d 3e 57 72 69 74 65 28 | 62 75 66 66 65 72 2c 20 |->Write(|buffer, | |00002fa0| 62 75 66 6c 65 6e 29 29 | 2c 20 53 50 5f 53 54 52 |buflen))|, SP_STR| |00002fb0| 45 41 4d 5f 57 52 49 54 | 45 2c 20 30 29 3b 0d 09 |EAM_WRIT|E, 0);..| |00002fc0| 09 69 66 20 28 61 76 61 | 69 6c 20 3d 3d 20 2d 31 |.if (ava|il == -1| |00002fd0| 29 20 7b 0d 09 09 09 69 | 66 20 28 21 65 72 72 6e |) {....i|f (!errn| |00002fe0| 6f 29 0d 09 09 09 09 47 | 55 53 49 5f 65 72 72 6f |o).....G|USI_erro| |00002ff0| 72 28 70 65 65 72 2d 3e | 65 72 72 6e 6f 29 3b 0d |r(peer->|errno);.| |00003000| 09 09 09 09 0d 09 09 09 | 62 72 65 61 6b 3b 0d 09 |........|break;..| |00003010| 09 7d 20 0d 09 09 0d 09 | 09 64 6f 6e 65 20 2b 3d |.} .....|.done +=| |00003020| 20 61 76 61 69 6c 3b 0d | 09 09 0d 09 09 69 66 20 | avail;.|.....if | |00003030| 28 6e 6f 6e 62 6c 6f 63 | 6b 69 6e 67 29 0d 09 09 |(nonbloc|king)...| |00003040| 09 62 72 65 61 6b 3b 0d | 09 7d 0d 09 09 09 0d 09 |.break;.|.}......| |00003050| 72 65 74 75 72 6e 20 64 | 6f 6e 65 20 3f 20 64 6f |return d|one ? do| |00003060| 6e 65 20 3a 20 28 62 75 | 66 6c 65 6e 20 3f 20 2d |ne : (bu|flen ? -| |00003070| 31 20 3a 20 30 29 3b 0d | 7d 0d 0d 2f 2a 2a 2a 2a |1 : 0);.|}../****| |00003080| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00003090| 2a 20 55 6e 69 78 44 67 | 72 61 6d 53 6f 63 6b 65 |* UnixDg|ramSocke| |000030a0| 74 20 6d 65 6d 62 65 72 | 73 20 2a 2a 2a 2a 2a 2a |t member|s ******| |000030b0| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |000030c0| 2f 0d 0d 55 6e 69 78 44 | 67 72 61 6d 53 6f 63 6b |/..UnixD|gramSock| |000030d0| 65 74 3a 3a 55 6e 69 78 | 44 67 72 61 6d 53 6f 63 |et::Unix|DgramSoc| |000030e0| 6b 65 74 28 29 0d 09 3a | 09 55 6e 69 78 53 6f 63 |ket()..:|.UnixSoc| |000030f0| 6b 65 74 28 53 4f 43 4b | 5f 44 47 52 41 4d 29 0d |ket(SOCK|_DGRAM).| |00003100| 7b 0d 7d 0d 0d 55 6e 69 | 78 44 67 72 61 6d 53 6f |{.}..Uni|xDgramSo| |00003110| 63 6b 65 74 3a 3a 7e 55 | 6e 69 78 44 67 72 61 6d |cket::~U|nixDgram| |00003120| 53 6f 63 6b 65 74 28 29 | 0d 7b 0d 7d 0d 0d 69 6e |Socket()|.{.}..in| |00003130| 74 20 55 6e 69 78 44 67 | 72 61 6d 53 6f 63 6b 65 |t UnixDg|ramSocke| |00003140| 74 3a 3a 63 6f 6e 6e 65 | 63 74 28 76 6f 69 64 20 |t::conne|ct(void | |00003150| 2a 73 61 5f 6e 61 6d 65 | 2c 20 69 6e 74 20 73 61 |*sa_name|, int sa| |00003160| 5f 6e 61 6d 65 6c 65 6e | 29 0d 7b 0d 09 55 6e 69 |_namelen|).{..Uni| |00003170| 78 53 6f 63 6b 65 74 41 | 64 64 72 20 2a 09 61 64 |xSocketA|ddr *.ad| |00003180| 64 72 3b 0d 09 0d 09 61 | 64 64 72 09 3d 09 43 61 |dr;....a|ddr.=.Ca| |00003190| 6e 6f 6e 69 7a 65 4e 61 | 6d 65 28 73 61 5f 6e 61 |nonizeNa|me(sa_na| |000031a0| 6d 65 2c 20 73 61 5f 6e | 61 6d 65 6c 65 6e 29 3b |me, sa_n|amelen);| |000031b0| 0d 09 0d 09 69 66 20 28 | 21 61 64 64 72 29 0d 09 |....if (|!addr)..| |000031c0| 09 72 65 74 75 72 6e 20 | 2d 31 3b 0d 09 0d 09 70 |.return |-1;....p| |000031d0| 65 65 72 20 3d 20 4c 6f | 6f 6b 75 70 4e 61 6d 65 |eer = Lo|okupName| |000031e0| 28 2a 61 64 64 72 29 3b | 0d 09 0d 09 69 66 20 28 |(*addr);|....if (| |000031f0| 21 70 65 65 72 29 0d 09 | 09 72 65 74 75 72 6e 20 |!peer)..|.return | |00003200| 47 55 53 49 5f 65 72 72 | 6f 72 28 45 41 44 44 52 |GUSI_err|or(EADDR| |00003210| 4e 4f 54 41 56 41 49 4c | 29 3b 0d 09 0d 09 73 74 |NOTAVAIL|);....st| |00003220| 61 74 65 09 3d 09 53 4f | 43 4b 5f 53 54 41 54 45 |ate.=.SO|CK_STATE| |00003230| 5f 43 4f 4e 4e 45 43 54 | 45 44 3b 0d 09 0d 09 72 |_CONNECT|ED;....r| |00003240| 65 74 75 72 6e 20 30 3b | 0d 7d 0d 0d 69 6e 74 20 |eturn 0;|.}..int | |00003250| 55 6e 69 78 44 67 72 61 | 6d 53 6f 63 6b 65 74 3a |UnixDgra|mSocket:| |00003260| 3a 72 65 63 76 66 72 6f | 6d 28 76 6f 69 64 20 2a |:recvfro|m(void *| |00003270| 20 62 75 66 66 65 72 2c | 20 69 6e 74 20 62 75 66 | buffer,| int buf| |00003280| 6c 65 6e 2c 20 69 6e 74 | 20 66 6c 61 67 73 2c 20 |len, int| flags, | |00003290| 76 6f 69 64 20 2a 20 66 | 72 6f 6d 2c 20 69 6e 74 |void * f|rom, int| |000032a0| 20 2a 20 66 72 6f 6d 6c | 65 6e 29 0d 7b 0d 09 55 | * froml|en).{..U| |000032b0| 6e 69 78 43 68 61 6e 6e | 65 6c 20 2a 20 09 70 61 |nixChann|el * .pa| |000032c0| 72 74 6e 65 72 3b 0d 09 | 69 6e 74 09 09 09 09 6c |rtner;..|int....l| |000032d0| 65 6e 67 74 68 3b 0d 09 | 69 6e 74 09 09 09 09 61 |ength;..|int....a| |000032e0| 76 61 69 6c 3b 0d 09 0d | 09 69 66 20 28 66 6c 61 |vail;...|.if (fla| |000032f0| 67 73 29 0d 09 09 72 65 | 74 75 72 6e 20 47 55 53 |gs)...re|turn GUS| |00003300| 49 5f 65 72 72 6f 72 28 | 45 4f 50 4e 4f 54 53 55 |I_error(|EOPNOTSU| |00003310| 50 50 29 3b 0d 09 69 66 | 20 28 21 63 68 61 6e 20 |PP);..if| (!chan | |00003320| 7c 7c 20 21 63 68 61 6e | 2d 3e 41 64 64 72 65 73 ||| !chan|->Addres| |00003330| 73 28 29 2e 76 61 6c 69 | 64 29 0d 09 09 72 65 74 |s().vali|d)...ret| |00003340| 75 72 6e 20 47 55 53 49 | 5f 65 72 72 6f 72 28 45 |urn GUSI|_error(E| |00003350| 4e 4f 54 43 4f 4e 4e 29 | 3b 09 2f 2f 20 66 75 63 |NOTCONN)|;.// fuc| |00003360| 6b 20 55 4e 49 58 20 73 | 65 6d 61 6e 74 69 63 73 |k UNIX s|emantics| |00003370| 3b 20 69 74 27 73 20 69 | 6d 70 6f 73 73 69 62 6c |; it's i|mpossibl| |00003380| 65 20 66 6f 72 20 61 6e | 6f 74 68 65 72 0d 09 09 |e for an|other...| |00003390| 09 09 09 09 09 09 09 09 | 09 09 2f 2f 20 73 6f 63 |........|..// soc| |000033a0| 6b 65 74 20 74 6f 20 63 | 6f 6d 6d 75 6e 69 63 61 |ket to c|ommunica| |000033b0| 74 65 20 77 69 74 68 20 | 74 68 69 73 20 6f 6e 65 |te with |this one| |000033c0| 2c 20 61 6e 79 77 61 79 | 0d 09 09 0d 09 69 66 20 |, anyway|.....if | |000033d0| 28 28 61 76 61 69 6c 20 | 3d 20 63 68 61 6e 2d 3e |((avail |= chan->| |000033e0| 52 65 61 64 41 76 61 69 | 6c 28 29 29 20 3d 3d 20 |ReadAvai|l()) == | |000033f0| 2d 31 29 0d 09 09 72 65 | 74 75 72 6e 20 47 55 53 |-1)...re|turn GUS| |00003400| 49 5f 65 72 72 6f 72 28 | 63 68 61 6e 2d 3e 65 72 |I_error(|chan->er| |00003410| 72 6e 6f 29 3b 0d 09 0d | 09 2f 2f 20 44 61 74 61 |rno);...|.// Data| |00003420| 67 72 61 6d 20 73 6f 63 | 6b 65 74 73 20 63 6f 6d |gram soc|kets com| |00003430| 6d 75 6e 69 63 61 74 65 | 20 74 68 65 20 73 65 6e |municate| the sen| |00003440| 64 65 72 27 73 20 61 64 | 64 72 65 73 73 20 69 6e |der's ad|dress in| |00003450| 20 74 68 65 20 66 69 72 | 73 74 20 34 20 62 79 74 | the fir|st 4 byt| |00003460| 65 73 0d 09 2f 2f 20 54 | 68 65 20 74 72 61 6e 73 |es..// T|he trans| |00003470| 66 65 72 20 77 69 6c 6c | 20 62 65 20 61 74 6f 6d |fer will| be atom| |00003480| 69 63 2c 20 73 6f 20 6f | 6e 6c 79 20 6f 6e 65 20 |ic, so o|nly one | |00003490| 73 70 69 6e 20 69 73 20 | 6e 65 65 64 65 64 0d 09 |spin is |needed..| |000034a0| 0d 09 69 66 20 28 6e 6f | 6e 62 6c 6f 63 6b 69 6e |..if (no|nblockin| |000034b0| 67 20 26 26 20 21 61 76 | 61 69 6c 29 0d 09 09 72 |g && !av|ail)...r| |000034c0| 65 74 75 72 6e 20 47 55 | 53 49 5f 65 72 72 6f 72 |eturn GU|SI_error| |000034d0| 28 45 57 4f 55 4c 44 42 | 4c 4f 43 4b 29 3b 0d 09 |(EWOULDB|LOCK);..| |000034e0| 0d 09 65 72 72 6e 6f 09 | 3d 09 30 3b 0d 09 53 50 |..errno.|=.0;..SP| |000034f0| 49 4e 28 21 28 61 76 61 | 69 6c 20 3d 20 63 68 61 |IN(!(ava|il = cha| |00003500| 6e 2d 3e 52 65 61 64 28 | 26 70 61 72 74 6e 65 72 |n->Read(|&partner| |00003510| 2c 20 73 69 7a 65 6f 66 | 28 55 6e 69 78 43 68 61 |, sizeof|(UnixCha| |00003520| 6e 6e 65 6c 20 2a 29 29 | 29 2c 20 53 50 5f 44 47 |nnel *))|), SP_DG| |00003530| 52 41 4d 5f 52 45 41 44 | 2c 20 30 29 3b 0d 09 69 |RAM_READ|, 0);..i| |00003540| 66 20 28 65 72 72 6e 6f | 29 0d 09 09 72 65 74 75 |f (errno|)...retu| |00003550| 72 6e 20 2d 31 3b 0d 09 | 65 6c 73 65 20 69 66 20 |rn -1;..|else if | |00003560| 28 61 76 61 69 6c 20 3d | 3d 20 2d 31 29 0d 09 09 |(avail =|= -1)...| |00003570| 72 65 74 75 72 6e 20 47 | 55 53 49 5f 65 72 72 6f |return G|USI_erro| |00003580| 72 28 63 68 61 6e 2d 3e | 65 72 72 6e 6f 29 3b 0d |r(chan->|errno);.| |00003590| 09 65 6c 73 65 20 69 66 | 20 28 61 76 61 69 6c 20 |.else if| (avail | |000035a0| 3c 20 73 69 7a 65 6f 66 | 28 55 6e 69 78 43 68 61 |< sizeof|(UnixCha| |000035b0| 6e 6e 65 6c 20 2a 29 29 | 0d 09 09 72 65 74 75 72 |nnel *))|...retur| |000035c0| 6e 20 47 55 53 49 5f 65 | 72 72 6f 72 28 45 46 41 |n GUSI_e|rror(EFA| |000035d0| 55 4c 54 29 3b 0d 0d 09 | 69 66 20 28 28 61 76 61 |ULT);...|if ((ava| |000035e0| 69 6c 20 3d 20 63 68 61 | 6e 2d 3e 52 65 61 64 28 |il = cha|n->Read(| |000035f0| 26 6c 65 6e 67 74 68 2c | 20 73 69 7a 65 6f 66 28 |&length,| sizeof(| |00003600| 6c 6f 6e 67 29 29 29 20 | 3d 3d 20 2d 31 29 0d 09 |long))) |== -1)..| |00003610| 09 72 65 74 75 72 6e 20 | 47 55 53 49 5f 65 72 72 |.return |GUSI_err| |00003620| 6f 72 28 63 68 61 6e 2d | 3e 65 72 72 6e 6f 29 3b |or(chan-|>errno);| |00003630| 0d 09 0d 09 62 75 66 6c | 65 6e 20 3d 20 6d 69 6e |....bufl|en = min| |00003640| 28 62 75 66 6c 65 6e 2c | 20 6c 65 6e 67 74 68 29 |(buflen,| length)| |00003650| 3b 0d 09 0d 09 69 66 20 | 28 28 61 76 61 69 6c 20 |;....if |((avail | |00003660| 3d 20 63 68 61 6e 2d 3e | 52 65 61 64 28 62 75 66 |= chan->|Read(buf| |00003670| 66 65 72 2c 20 62 75 66 | 6c 65 6e 29 29 20 3d 3d |fer, buf|len)) ==| |00003680| 20 2d 31 29 0d 09 09 72 | 65 74 75 72 6e 20 47 55 | -1)...r|eturn GU| |00003690| 53 49 5f 65 72 72 6f 72 | 28 63 68 61 6e 2d 3e 65 |SI_error|(chan->e| |000036a0| 72 72 6e 6f 29 3b 0d 09 | 09 0d 09 63 68 61 6e 2d |rrno);..|...chan-| |000036b0| 3e 44 69 73 63 61 72 64 | 52 65 61 64 28 6c 65 6e |>Discard|Read(len| |000036c0| 67 74 68 20 2d 20 62 75 | 66 6c 65 6e 29 3b 0d 09 |gth - bu|flen);..| |000036d0| 0d 09 55 6e 63 61 6e 6f | 6e 69 7a 65 4e 61 6d 65 |..Uncano|nizeName| |000036e0| 28 70 61 72 74 6e 65 72 | 2d 3e 41 64 64 72 65 73 |(partner|->Addres| |000036f0| 73 28 29 2c 20 66 72 6f | 6d 2c 20 66 72 6f 6d 6c |s(), fro|m, froml| |00003700| 65 6e 29 3b 0d 09 09 0d | 09 72 65 74 75 72 6e 20 |en);....|.return | |00003710| 61 76 61 69 6c 3b 0d 7d | 0d 0d 69 6e 74 20 55 6e |avail;.}|..int Un| |00003720| 69 78 44 67 72 61 6d 53 | 6f 63 6b 65 74 3a 3a 73 |ixDgramS|ocket::s| |00003730| 65 6e 64 74 6f 28 76 6f | 69 64 20 2a 20 62 75 66 |endto(vo|id * buf| |00003740| 66 65 72 2c 20 69 6e 74 | 20 62 75 66 6c 65 6e 2c |fer, int| buflen,| |00003750| 20 69 6e 74 20 66 6c 61 | 67 73 2c 20 76 6f 69 64 | int fla|gs, void| |00003760| 20 2a 20 74 6f 2c 20 69 | 6e 74 20 74 6f 6c 65 6e | * to, i|nt tolen| |00003770| 29 0d 7b 0d 09 55 6e 69 | 78 53 6f 63 6b 65 74 41 |).{..Uni|xSocketA| |00003780| 64 64 72 20 2a 09 61 64 | 64 72 3b 0d 09 55 6e 69 |ddr *.ad|dr;..Uni| |00003790| 78 43 68 61 6e 6e 65 6c | 20 2a 20 09 09 70 61 72 |xChannel| * ..par| |000037a0| 74 6e 65 72 3b 0d 09 69 | 6e 74 09 09 09 09 09 6c |tner;..i|nt.....l| |000037b0| 65 6e 67 74 68 3b 0d 09 | 69 6e 74 09 09 09 09 09 |ength;..|int.....| |000037c0| 61 76 61 69 6c 3b 0d 09 | 0d 09 69 66 20 28 66 6c |avail;..|..if (fl| |000037d0| 61 67 73 29 0d 09 09 72 | 65 74 75 72 6e 20 47 55 |ags)...r|eturn GU| |000037e0| 53 49 5f 65 72 72 6f 72 | 28 45 4f 50 4e 4f 54 53 |SI_error|(EOPNOTS| |000037f0| 55 50 50 29 3b 0d 09 69 | 66 20 28 21 63 68 61 6e |UPP);..i|f (!chan| |00003800| 29 0d 09 09 63 68 61 6e | 20 3d 20 6e 65 77 20 55 |)...chan| = new U| |00003810| 6e 69 78 43 68 61 6e 6e | 65 6c 32 28 74 68 69 73 |nixChann|el2(this| |00003820| 29 3b 0d 09 69 66 20 28 | 70 65 65 72 29 09 0d 09 |);..if (|peer)...| |00003830| 09 70 61 72 74 6e 65 72 | 09 3d 09 70 65 65 72 3b |.partner|.=.peer;| |00003840| 0d 09 65 6c 73 65 20 7b | 0d 09 09 61 64 64 72 09 |..else {|...addr.| |00003850| 3d 09 43 61 6e 6f 6e 69 | 7a 65 4e 61 6d 65 28 74 |=.Canoni|zeName(t| |00003860| 6f 2c 20 74 6f 6c 65 6e | 29 3b 0d 09 09 0d 09 09 |o, tolen|);......| |00003870| 69 66 20 28 21 61 64 64 | 72 29 0d 09 09 09 72 65 |if (!add|r)....re| |00003880| 74 75 72 6e 20 2d 31 3b | 0d 09 09 0d 09 09 70 61 |turn -1;|......pa| |00003890| 72 74 6e 65 72 20 3d 20 | 4c 6f 6f 6b 75 70 4e 61 |rtner = |LookupNa| |000038a0| 6d 65 28 2a 61 64 64 72 | 29 3b 0d 09 09 0d 09 09 |me(*addr|);......| |000038b0| 69 66 20 28 21 70 61 72 | 74 6e 65 72 29 0d 09 09 |if (!par|tner)...| |000038c0| 09 72 65 74 75 72 6e 20 | 47 55 53 49 5f 65 72 72 |.return |GUSI_err| |000038d0| 6f 72 28 45 41 44 44 52 | 4e 4f 54 41 56 41 49 4c |or(EADDR|NOTAVAIL| |000038e0| 29 3b 0d 09 7d 0d 09 09 | 09 0d 09 6c 65 6e 67 74 |);..}...|...lengt| |000038f0| 68 09 3d 09 73 69 7a 65 | 6f 66 28 55 6e 69 78 43 |h.=.size|of(UnixC| |00003900| 68 61 6e 6e 65 6c 20 2a | 29 20 2b 20 73 69 7a 65 |hannel *|) + size| |00003910| 6f 66 28 69 6e 74 29 20 | 2b 20 62 75 66 6c 65 6e |of(int) |+ buflen| |00003920| 3b 0d 09 0d 09 69 66 20 | 28 6c 65 6e 67 74 68 20 |;....if |(length | |00003930| 3e 20 70 61 72 74 6e 65 | 72 2d 3e 42 75 66 53 69 |> partne|r->BufSi| |00003940| 7a 65 28 29 29 0d 09 09 | 72 65 74 75 72 6e 20 47 |ze())...|return G| |00003950| 55 53 49 5f 65 72 72 6f | 72 28 45 4d 53 47 53 49 |USI_erro|r(EMSGSI| |00003960| 5a 45 29 3b 0d 09 69 66 | 20 28 28 61 76 61 69 6c |ZE);..if| ((avail| |00003970| 20 3d 20 70 61 72 74 6e | 65 72 2d 3e 57 72 69 74 | = partn|er->Writ| |00003980| 65 41 76 61 69 6c 28 29 | 29 20 3d 3d 20 2d 31 29 |eAvail()|) == -1)| |00003990| 0d 09 09 72 65 74 75 72 | 6e 20 47 55 53 49 5f 65 |...retur|n GUSI_e| |000039a0| 72 72 6f 72 28 70 61 72 | 74 6e 65 72 2d 3e 65 72 |rror(par|tner->er| |000039b0| 72 6e 6f 29 3b 0d 09 69 | 66 20 28 61 76 61 69 6c |rno);..i|f (avail| |000039c0| 20 3c 20 6c 65 6e 67 74 | 68 29 0d 09 09 69 66 20 | < lengt|h)...if | |000039d0| 28 6e 6f 6e 62 6c 6f 63 | 6b 69 6e 67 29 0d 09 09 |(nonbloc|king)...| |000039e0| 09 72 65 74 75 72 6e 20 | 47 55 53 49 5f 65 72 72 |.return |GUSI_err| |000039f0| 6f 72 28 45 57 4f 55 4c | 44 42 4c 4f 43 4b 29 3b |or(EWOUL|DBLOCK);| |00003a00| 0d 09 09 65 6c 73 65 0d | 09 09 09 53 50 49 4e 28 |...else.|...SPIN(| |00003a10| 28 61 76 61 69 6c 3d 70 | 61 72 74 6e 65 72 2d 3e |(avail=p|artner->| |00003a20| 57 72 69 74 65 41 76 61 | 69 6c 28 29 29 20 21 3d |WriteAva|il()) !=| |00003a30| 20 2d 31 20 26 26 20 61 | 76 61 69 6c 3c 6c 65 6e | -1 && a|vail<len| |00003a40| 67 74 68 2c 20 53 50 5f | 44 47 52 41 4d 5f 57 52 |gth, SP_|DGRAM_WR| |00003a50| 49 54 45 2c 20 30 29 3b | 0d 09 0d 09 69 66 20 28 |ITE, 0);|....if (| |00003a60| 61 76 61 69 6c 20 3d 3d | 20 2d 31 29 0d 09 09 72 |avail ==| -1)...r| |00003a70| 65 74 75 72 6e 20 47 55 | 53 49 5f 65 72 72 6f 72 |eturn GU|SI_error| |00003a80| 28 70 61 72 74 6e 65 72 | 2d 3e 65 72 72 6e 6f 29 |(partner|->errno)| |00003a90| 3b 0d 09 09 0d 09 65 72 | 72 6e 6f 09 3d 09 30 3b |;.....er|rno.=.0;| |00003aa0| 0d 09 53 50 49 4e 28 21 | 28 61 76 61 69 6c 20 3d |..SPIN(!|(avail =| |00003ab0| 20 70 61 72 74 6e 65 72 | 2d 3e 53 65 6e 64 28 63 | partner|->Send(c| |00003ac0| 68 61 6e 2c 20 62 75 66 | 66 65 72 2c 20 62 75 66 |han, buf|fer, buf| |00003ad0| 6c 65 6e 29 29 2c 20 53 | 50 5f 44 47 52 41 4d 5f |len)), S|P_DGRAM_| |00003ae0| 57 52 49 54 45 2c 20 30 | 29 3b 0d 09 69 66 20 28 |WRITE, 0|);..if (| |00003af0| 65 72 72 6e 6f 29 0d 09 | 09 72 65 74 75 72 6e 20 |errno)..|.return | |00003b00| 2d 31 3b 0d 09 65 6c 73 | 65 20 69 66 20 28 61 76 |-1;..els|e if (av| |00003b10| 61 69 6c 20 3d 3d 20 2d | 31 29 0d 09 09 72 65 74 |ail == -|1)...ret| |00003b20| 75 72 6e 20 47 55 53 49 | 5f 65 72 72 6f 72 28 70 |urn GUSI|_error(p| |00003b30| 61 72 74 6e 65 72 2d 3e | 65 72 72 6e 6f 29 3b 0d |artner->|errno);.| |00003b40| 09 09 0d 09 72 65 74 75 | 72 6e 20 61 76 61 69 6c |....retu|rn avail| |00003b50| 3b 0d 7d 0d 0d 2f 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |;.}../**|********| |00003b60| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 20 55 6e |********|***** Un| |00003b70| 69 78 43 68 61 6e 6e 65 | 6c 20 6d 65 6d 62 65 72 |ixChanne|l member| |00003b80| 73 20 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |s ******|********| |00003b90| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2f 0d 0d 55 6e 69 |********|**/..Uni| |00003ba0| 78 43 68 61 6e 6e 65 6c | 3a 3a 55 6e 69 78 43 68 |xChannel|::UnixCh| |00003bb0| 61 6e 6e 65 6c 28 55 6e | 69 78 53 6f 63 6b 65 74 |annel(Un|ixSocket| |00003bc0| 20 2a 20 6f 77 6e 65 72 | 29 0d 09 3a 09 61 64 64 | * owner|)..:.add| |00003bd0| 72 65 73 73 28 55 6e 69 | 78 53 6f 63 6b 65 74 41 |ress(Uni|xSocketA| |00003be0| 64 64 72 28 29 29 2c 20 | 73 6f 63 6b 28 6f 77 6e |ddr()), |sock(own| |00003bf0| 65 72 29 0d 7b 0d 7d 0d | 0d 55 6e 69 78 43 68 61 |er).{.}.|.UnixCha| |00003c00| 6e 6e 65 6c 3a 3a 7e 55 | 6e 69 78 43 68 61 6e 6e |nnel::~U|nixChann| |00003c10| 65 6c 28 29 0d 7b 0d 09 | 69 66 20 28 61 64 64 72 |el().{..|if (addr| |00003c20| 65 73 73 2e 76 61 6c 69 | 64 29 0d 09 09 55 6e 42 |ess.vali|d)...UnB| |00003c30| 69 6e 64 28 29 3b 0d 7d | 0d 0d 76 6f 69 64 20 55 |ind();.}|..void U| |00003c40| 6e 69 78 43 68 61 6e 6e | 65 6c 3a 3a 55 6e 42 69 |nixChann|el::UnBi| |00003c50| 6e 64 28 29 0d 7b 0d 09 | 69 66 20 28 61 64 64 72 |nd().{..|if (addr| |00003c60| 65 73 73 2e 6f 77 6e 65 | 64 29 0d 09 09 48 44 65 |ess.owne|d)...HDe| |00003c70| 6c 65 74 65 28 61 64 64 | 72 65 73 73 2e 76 52 65 |lete(add|ress.vRe| |00003c80| 66 4e 75 6d 2c 20 61 64 | 64 72 65 73 73 2e 70 61 |fNum, ad|dress.pa| |00003c90| 72 49 44 2c 20 61 64 64 | 72 65 73 73 2e 6e 61 6d |rID, add|ress.nam| |00003ca0| 65 29 3b 09 09 0d 7d 0d | 0d 69 6e 74 20 55 6e 69 |e);...}.|.int Uni| |00003cb0| 78 43 68 61 6e 6e 65 6c | 3a 3a 56 65 72 73 69 6f |xChannel|::Versio| |00003cc0| 6e 28 29 0d 7b 0d 09 72 | 65 74 75 72 6e 20 31 3b |n().{..r|eturn 1;| |00003cd0| 0d 7d 0d 0d 42 6f 6f 6c | 65 61 6e 20 55 6e 69 78 |.}..Bool|ean Unix| |00003ce0| 43 68 61 6e 6e 65 6c 3a | 3a 42 69 6e 64 28 55 6e |Channel:|:Bind(Un| |00003cf0| 69 78 53 6f 63 6b 65 74 | 41 64 64 72 20 26 20 61 |ixSocket|Addr & a| |00003d00| 64 64 72 29 0d 7b 0d 09 | 73 68 6f 72 74 09 09 09 |ddr).{..|short...| |00003d10| 09 72 65 73 46 69 6c 65 | 3b 0d 09 73 68 6f 72 74 |.resFile|;..short| |00003d20| 09 09 09 09 6f 6c 64 52 | 65 73 46 69 6c 65 09 3d |....oldR|esFile.=| |00003d30| 09 43 75 72 52 65 73 46 | 69 6c 65 28 29 3b 0d 09 |.CurResF|ile();..| |00003d40| 48 61 6e 64 6c 65 09 09 | 09 49 44 3b 0d 09 55 6e |Handle..|.ID;..Un| |00003d50| 69 78 53 6f 63 6b 65 74 | 49 44 09 6d 65 28 74 68 |ixSocket|ID.me(th| |00003d60| 69 73 29 3b 0d 09 46 49 | 6e 66 6f 09 09 09 09 69 |is);..FI|nfo....i| |00003d70| 6e 66 6f 3b 0d 09 0d 09 | 61 64 64 72 65 73 73 09 |nfo;....|address.| |00003d80| 3d 09 61 64 64 72 3b 0d | 09 0d 09 69 66 20 28 50 |=.addr;.|...if (P| |00003d90| 74 72 54 6f 48 61 6e 64 | 28 26 6d 65 2c 20 26 49 |trToHand|(&me, &I| |00003da0| 44 2c 20 73 69 7a 65 6f | 66 28 55 6e 69 78 53 6f |D, sizeo|f(UnixSo| |00003db0| 63 6b 65 74 49 44 29 29 | 29 0d 09 09 72 65 74 75 |cketID))|)...retu| |00003dc0| 72 6e 20 66 61 6c 73 65 | 3b 0d 09 09 0d 09 48 44 |rn false|;.....HD| |00003dd0| 65 6c 65 74 65 28 61 64 | 64 72 65 73 73 2e 76 52 |elete(ad|dress.vR| |00003de0| 65 66 4e 75 6d 2c 20 61 | 64 64 72 65 73 73 2e 70 |efNum, a|ddress.p| |00003df0| 61 72 49 44 2c 20 61 64 | 64 72 65 73 73 2e 6e 61 |arID, ad|dress.na| |00003e00| 6d 65 29 3b 0d 09 48 43 | 72 65 61 74 65 28 61 64 |me);..HC|reate(ad| |00003e10| 64 72 65 73 73 2e 76 52 | 65 66 4e 75 6d 2c 20 61 |dress.vR|efNum, a| |00003e20| 64 64 72 65 73 73 2e 70 | 61 72 49 44 2c 20 61 64 |ddress.p|arID, ad| |00003e30| 64 72 65 73 73 2e 6e 61 | 6d 65 2c 20 27 47 55 b7 |dress.na|me, 'GU.| |00003e40| 49 27 2c 20 27 b7 4f 43 | 4b 27 29 3b 0d 09 48 43 |I', '.OC|K');..HC| |00003e50| 72 65 61 74 65 52 65 73 | 46 69 6c 65 28 61 64 64 |reateRes|File(add| |00003e60| 72 65 73 73 2e 76 52 65 | 66 4e 75 6d 2c 20 61 64 |ress.vRe|fNum, ad| |00003e70| 64 72 65 73 73 2e 70 61 | 72 49 44 2c 20 61 64 64 |dress.pa|rID, add| |00003e80| 72 65 73 73 2e 6e 61 6d | 65 29 3b 0d 09 72 65 73 |ress.nam|e);..res| |00003e90| 46 69 6c 65 20 3d 20 48 | 4f 70 65 6e 52 65 73 46 |File = H|OpenResF| |00003ea0| 69 6c 65 28 61 64 64 72 | 65 73 73 2e 76 52 65 66 |ile(addr|ess.vRef| |00003eb0| 4e 75 6d 2c 20 61 64 64 | 72 65 73 73 2e 70 61 72 |Num, add|ress.par| |00003ec0| 49 44 2c 20 61 64 64 72 | 65 73 73 2e 6e 61 6d 65 |ID, addr|ess.name| |00003ed0| 2c 20 66 73 52 64 57 72 | 50 65 72 6d 29 3b 0d 09 |, fsRdWr|Perm);..| |00003ee0| 0d 09 69 66 20 28 72 65 | 73 46 69 6c 65 20 3d 3d |..if (re|sFile ==| |00003ef0| 20 2d 31 29 09 7b 0d 09 | 09 44 69 73 70 6f 73 65 | -1).{..|.Dispose| |00003f00| 48 61 6e 64 6c 65 28 49 | 44 29 3b 0d 09 09 72 65 |Handle(I|D);...re| |00003f10| 74 75 72 6e 20 66 61 6c | 73 65 3b 0d 09 7d 0d 09 |turn fal|se;..}..| |00003f20| 0d 09 41 64 64 52 65 73 | 6f 75 72 63 65 28 49 44 |..AddRes|ource(ID| |00003f30| 2c 20 27 47 55 b7 49 27 | 2c 20 47 55 53 49 52 73 |, 'GU.I'|, GUSIRs| |00003f40| 72 63 49 44 2c 20 22 5c | 70 22 29 3b 0d 09 0d 09 |rcID, "\|p");....| |00003f50| 69 66 20 28 52 65 73 45 | 72 72 6f 72 28 29 29 20 |if (ResE|rror()) | |00003f60| 7b 0d 09 09 43 6c 6f 73 | 65 52 65 73 46 69 6c 65 |{...Clos|eResFile| |00003f70| 28 72 65 73 46 69 6c 65 | 29 3b 0d 09 09 48 44 65 |(resFile|);...HDe| |00003f80| 6c 65 74 65 28 61 64 64 | 72 65 73 73 2e 76 52 65 |lete(add|ress.vRe| |00003f90| 66 4e 75 6d 2c 20 61 64 | 64 72 65 73 73 2e 70 61 |fNum, ad|dress.pa| |00003fa0| 72 49 44 2c 20 61 64 64 | 72 65 73 73 2e 6e 61 6d |rID, add|ress.nam| |00003fb0| 65 29 3b 0d 09 09 44 69 | 73 70 6f 73 65 48 61 6e |e);...Di|sposeHan| |00003fc0| 64 6c 65 28 49 44 29 3b | 0d 09 09 55 73 65 52 65 |dle(ID);|...UseRe| |00003fd0| 73 46 69 6c 65 28 6f 6c | 64 52 65 73 46 69 6c 65 |sFile(ol|dResFile| |00003fe0| 29 3b 0d 09 09 72 65 74 | 75 72 6e 20 66 61 6c 73 |);...ret|urn fals| |00003ff0| 65 3b 0d 09 7d 0d 0d 09 | 43 6f 70 79 49 63 6f 6e |e;..}...|CopyIcon| |00004000| 46 61 6d 69 6c 79 28 2a | 28 73 68 6f 72 74 20 2a |Family(*|(short *| |00004010| 29 20 43 75 72 41 70 52 | 65 66 4e 75 6d 2c 20 47 |) CurApR|efNum, G| |00004020| 55 53 49 52 73 72 63 49 | 44 2c 20 72 65 73 46 69 |USIRsrcI|D, resFi| |00004030| 6c 65 2c 20 6b 43 75 73 | 74 6f 6d 49 63 6f 6e 52 |le, kCus|tomIconR| |00004040| 65 73 6f 75 72 63 65 29 | 3b 0d 09 0d 09 43 6c 6f |esource)|;....Clo| |00004050| 73 65 52 65 73 46 69 6c | 65 28 72 65 73 46 69 6c |seResFil|e(resFil| |00004060| 65 29 3b 0d 09 55 73 65 | 52 65 73 46 69 6c 65 28 |e);..Use|ResFile(| |00004070| 6f 6c 64 52 65 73 46 69 | 6c 65 29 3b 0d 0d 09 48 |oldResFi|le);...H| |00004080| 47 65 74 46 49 6e 66 6f | 28 61 64 64 72 65 73 73 |GetFInfo|(address| |00004090| 2e 76 52 65 66 4e 75 6d | 2c 20 61 64 64 72 65 73 |.vRefNum|, addres| |000040a0| 73 2e 70 61 72 49 44 2c | 20 61 64 64 72 65 73 73 |s.parID,| address| |000040b0| 2e 6e 61 6d 65 2c 20 26 | 69 6e 66 6f 29 3b 0d 09 |.name, &|info);..| |000040c0| 69 6e 66 6f 2e 66 64 46 | 6c 61 67 73 09 7c 3d 09 |info.fdF|lags.|=.| |000040d0| 28 31 20 3c 3c 20 31 30 | 29 3b 0d 09 69 6e 66 6f |(1 << 10|);..info| |000040e0| 2e 66 64 46 6c 61 67 73 | 09 26 3d 20 7e 28 31 20 |.fdFlags|.&= ~(1 | |000040f0| 3c 3c 20 38 29 3b 0d 09 | 48 53 65 74 46 49 6e 66 |<< 8);..|HSetFInf| |00004100| 6f 28 61 64 64 72 65 73 | 73 2e 76 52 65 66 4e 75 |o(addres|s.vRefNu| |00004110| 6d 2c 20 61 64 64 72 65 | 73 73 2e 70 61 72 49 44 |m, addre|ss.parID| |00004120| 2c 20 61 64 64 72 65 73 | 73 2e 6e 61 6d 65 2c 20 |, addres|s.name, | |00004130| 26 69 6e 66 6f 29 3b 0d | 09 09 0d 09 72 65 74 75 |&info);.|....retu| |00004140| 72 6e 20 74 72 75 65 3b | 0d 7d 0d 0d 42 6f 6f 6c |rn true;|.}..Bool| |00004150| 65 61 6e 20 55 6e 69 78 | 43 68 61 6e 6e 65 6c 3a |ean Unix|Channel:| |00004160| 3a 43 6f 6e 6e 65 63 74 | 28 55 6e 69 78 43 68 61 |:Connect|(UnixCha| |00004170| 6e 6e 65 6c 20 2a 20 63 | 68 29 0d 7b 0d 09 69 66 |nnel * c|h).{..if| |00004180| 20 28 73 6f 63 6b 2d 3e | 63 75 72 4c 69 73 74 65 | (sock->|curListe| |00004190| 6e 65 72 20 3e 3d 20 73 | 6f 63 6b 2d 3e 6d 61 78 |ner >= s|ock->max| |000041a0| 4c 69 73 74 65 6e 65 72 | 29 0d 09 09 72 65 74 75 |Listener|)...retu| |000041b0| 72 6e 20 66 61 6c 73 65 | 3b 0d 09 09 0d 09 73 77 |rn false|;.....sw| |000041c0| 69 74 63 68 20 28 73 6f | 63 6b 2d 3e 73 74 61 74 |itch (so|ck->stat| |000041d0| 65 29 09 7b 0d 09 63 61 | 73 65 20 53 4f 43 4b 5f |e).{..ca|se SOCK_| |000041e0| 53 54 41 54 45 5f 4c 49 | 53 54 45 4e 49 4e 47 3a |STATE_LI|STENING:| |000041f0| 0d 09 09 73 6f 63 6b 2d | 3e 73 74 61 74 65 09 3d |...sock-|>state.=| |00004200| 09 53 4f 43 4b 5f 53 54 | 41 54 45 5f 4c 49 53 5f |.SOCK_ST|ATE_LIS_| |00004210| 43 4f 4e 3b 0d 09 09 2f | 2f 20 46 61 6c 6c 20 74 |CON;.../|/ Fall t| |00004220| 68 72 6f 75 67 68 0d 09 | 63 61 73 65 20 53 4f 43 |hrough..|case SOC| |00004230| 4b 5f 53 54 41 54 45 5f | 4c 49 53 5f 43 4f 4e 3a |K_STATE_|LIS_CON:| |00004240| 0d 09 09 69 66 20 28 21 | 73 6f 63 6b 2d 3e 6c 61 |...if (!|sock->la| |00004250| 73 74 4c 69 73 74 65 6e | 65 72 29 0d 09 09 09 73 |stListen|er)....s| |00004260| 6f 63 6b 2d 3e 66 69 72 | 73 74 4c 69 73 74 65 6e |ock->fir|stListen| |00004270| 65 72 09 3d 09 63 68 3b | 0d 09 09 65 6c 73 65 0d |er.=.ch;|...else.| |00004280| 09 09 09 73 6f 63 6b 2d | 3e 6c 61 73 74 4c 69 73 |...sock-|>lastLis| |00004290| 74 65 6e 65 72 2d 3e 6e | 65 78 74 4c 69 73 74 65 |tener->n|extListe| |000042a0| 6e 65 72 20 3d 20 63 68 | 3b 0d 09 09 09 0d 09 09 |ner = ch|;.......| |000042b0| 73 6f 63 6b 2d 3e 6c 61 | 73 74 4c 69 73 74 65 6e |sock->la|stListen| |000042c0| 65 72 20 3d 20 63 68 3b | 0d 09 09 2b 2b 73 6f 63 |er = ch;|...++soc| |000042d0| 6b 2d 3e 63 75 72 4c 69 | 73 74 65 6e 65 72 3b 0d |k->curLi|stener;.| |000042e0| 09 09 0d 09 09 72 65 74 | 75 72 6e 20 74 72 75 65 |.....ret|urn true| |000042f0| 3b 0d 09 64 65 66 61 75 | 6c 74 3a 0d 09 09 72 65 |;..defau|lt:...re| |00004300| 74 75 72 6e 20 66 61 6c | 73 65 3b 0d 09 7d 0d 7d |turn fal|se;..}.}| |00004310| 0d 0d 42 6f 6f 6c 65 61 | 6e 20 55 6e 69 78 43 68 |..Boolea|n UnixCh| |00004320| 61 6e 6e 65 6c 3a 3a 41 | 63 63 65 70 74 28 55 6e |annel::A|ccept(Un| |00004330| 69 78 43 68 61 6e 6e 65 | 6c 20 2a 20 63 68 29 0d |ixChanne|l * ch).| |00004340| 7b 0d 09 69 66 20 28 21 | 73 6f 63 6b 29 0d 09 09 |{..if (!|sock)...| |00004350| 72 65 74 75 72 6e 20 74 | 72 75 65 3b 0d 09 09 0d |return t|rue;....| |00004360| 09 73 6f 63 6b 2d 3e 70 | 65 65 72 09 3d 09 63 68 |.sock->p|eer.=.ch| |00004370| 3b 0d 09 73 6f 63 6b 2d | 3e 73 74 61 74 65 09 3d |;..sock-|>state.=| |00004380| 09 53 4f 43 4b 5f 53 54 | 41 54 45 5f 43 4f 4e 4e |.SOCK_ST|ATE_CONN| |00004390| 45 43 54 45 44 3b 0d 09 | 0d 09 72 65 74 75 72 6e |ECTED;..|..return| |000043a0| 20 74 72 75 65 3b 0d 7d | 0d 0d 69 6e 74 20 55 6e | true;.}|..int Un| |000043b0| 69 78 43 68 61 6e 6e 65 | 6c 3a 3a 52 65 61 64 28 |ixChanne|l::Read(| |000043c0| 76 6f 69 64 20 2a 20 62 | 75 66 66 65 72 2c 20 69 |void * b|uffer, i| |000043d0| 6e 74 20 6c 65 6e 29 0d | 7b 0d 09 69 66 20 28 73 |nt len).|{..if (s| |000043e0| 6f 63 6b 2d 3e 73 74 61 | 74 75 73 20 26 20 53 4f |ock->sta|tus & SO| |000043f0| 43 4b 5f 53 54 41 54 55 | 53 5f 4e 4f 52 45 41 44 |CK_STATU|S_NOREAD| |00004400| 29 0d 09 09 72 65 74 75 | 72 6e 20 47 55 53 49 5f |)...retu|rn GUSI_| |00004410| 65 72 72 6f 72 28 45 53 | 48 55 54 44 4f 57 4e 29 |error(ES|HUTDOWN)| |00004420| 3b 0d 09 09 0d 09 50 74 | 72 09 73 74 61 72 74 42 |;.....Pt|r.startB| |00004430| 75 66 09 3d 20 28 50 74 | 72 29 20 62 75 66 66 65 |uf.= (Pt|r) buffe| |00004440| 72 3b 0d 09 69 6e 74 09 | 73 65 63 74 69 6f 6e 3b |r;..int.|section;| |00004450| 0d 09 09 0d 09 69 66 20 | 28 73 6f 63 6b 2d 3e 76 |.....if |(sock->v| |00004460| 61 6c 69 64 42 79 74 65 | 73 20 3e 20 30 29 09 7b |alidByte|s > 0).{| |00004470| 0d 09 09 73 65 63 74 69 | 6f 6e 09 3d 09 73 6f 63 |...secti|on.=.soc| |00004480| 6b 2d 3e 72 65 61 64 42 | 75 66 53 69 7a 65 2d 73 |k->readB|ufSize-s| |00004490| 6f 63 6b 2d 3e 72 65 61 | 64 50 6f 73 3b 0d 09 09 |ock->rea|dPos;...| |000044a0| 0d 09 09 69 66 20 28 73 | 65 63 74 69 6f 6e 20 3e |...if (s|ection >| |000044b0| 20 73 6f 63 6b 2d 3e 76 | 61 6c 69 64 42 79 74 65 | sock->v|alidByte| |000044c0| 73 29 0d 09 09 09 73 65 | 63 74 69 6f 6e 20 3d 20 |s)....se|ction = | |000044d0| 73 6f 63 6b 2d 3e 76 61 | 6c 69 64 42 79 74 65 73 |sock->va|lidBytes| |000044e0| 3b 0d 09 09 69 66 20 28 | 73 65 63 74 69 6f 6e 20 |;...if (|section | |000044f0| 3e 20 6c 65 6e 29 0d 09 | 09 09 73 65 63 74 69 6f |> len)..|..sectio| |00004500| 6e 20 3d 20 6c 65 6e 3b | 0d 09 09 0d 09 09 42 6c |n = len;|......Bl| |00004510| 6f 63 6b 4d 6f 76 65 28 | 73 6f 63 6b 2d 3e 72 65 |ockMove(|sock->re| |00004520| 61 64 42 75 66 2b 73 6f | 63 6b 2d 3e 72 65 61 64 |adBuf+so|ck->read| |00004530| 50 6f 73 2c 20 62 75 66 | 66 65 72 2c 20 73 65 63 |Pos, buf|fer, sec| |00004540| 74 69 6f 6e 29 3b 0d 09 | 09 0d 09 09 62 75 66 66 |tion);..|....buff| |00004550| 65 72 09 09 09 09 3d 20 | 28 63 68 61 72 20 2a 29 |er....= |(char *)| |00004560| 20 62 75 66 66 65 72 20 | 2b 20 73 65 63 74 69 6f | buffer |+ sectio| |00004570| 6e 3b 0d 09 09 73 6f 63 | 6b 2d 3e 72 65 61 64 50 |n;...soc|k->readP| |00004580| 6f 73 09 09 2b 3d 09 73 | 65 63 74 69 6f 6e 3b 0d |os..+=.s|ection;.| |00004590| 09 09 73 6f 63 6b 2d 3e | 76 61 6c 69 64 42 79 74 |..sock->|validByt| |000045a0| 65 73 09 2d 3d 09 73 65 | 63 74 69 6f 6e 3b 0d 09 |es.-=.se|ction;..| |000045b0| 09 6c 65 6e 20 09 09 09 | 09 09 2d 3d 20 73 65 63 |.len ...|..-= sec| |000045c0| 74 69 6f 6e 3b 0d 09 09 | 0d 09 09 69 66 20 28 73 |tion;...|...if (s| |000045d0| 6f 63 6b 2d 3e 72 65 61 | 64 50 6f 73 20 3d 3d 20 |ock->rea|dPos == | |000045e0| 73 6f 63 6b 2d 3e 72 65 | 61 64 42 75 66 53 69 7a |sock->re|adBufSiz| |000045f0| 65 29 0d 09 09 09 73 6f | 63 6b 2d 3e 72 65 61 64 |e)....so|ck->read| |00004600| 50 6f 73 09 3d 09 30 3b | 0d 09 7d 20 65 6c 73 65 |Pos.=.0;|..} else| |00004610| 20 69 66 20 28 73 6f 63 | 6b 2d 3e 73 74 61 74 65 | if (soc|k->state| |00004620| 20 21 3d 20 53 4f 43 4b | 5f 53 54 41 54 45 5f 43 | != SOCK|_STATE_C| |00004630| 4f 4e 4e 45 43 54 45 44 | 29 0d 09 09 72 65 74 75 |ONNECTED|)...retu| |00004640| 72 6e 20 47 55 53 49 5f | 65 72 72 6f 72 28 45 53 |rn GUSI_|error(ES| |00004650| 48 55 54 44 4f 57 4e 29 | 3b 0d 09 09 0d 09 69 66 |HUTDOWN)|;.....if| |00004660| 20 28 6c 65 6e 20 3e 20 | 30 20 26 26 20 73 6f 63 | (len > |0 && soc| |00004670| 6b 2d 3e 76 61 6c 69 64 | 42 79 74 65 73 20 3e 20 |k->valid|Bytes > | |00004680| 30 29 09 7b 0d 09 09 73 | 65 63 74 69 6f 6e 20 09 |0).{...s|ection .| |00004690| 3d 09 28 6c 65 6e 20 3e | 20 73 6f 63 6b 2d 3e 76 |=.(len >| sock->v| |000046a0| 61 6c 69 64 42 79 74 65 | 73 29 20 3f 20 73 6f 63 |alidByte|s) ? soc| |000046b0| 6b 2d 3e 76 61 6c 69 64 | 42 79 74 65 73 20 3a 20 |k->valid|Bytes : | |000046c0| 6c 65 6e 3b 0d 09 09 0d | 09 09 42 6c 6f 63 6b 4d |len;....|..BlockM| |000046d0| 6f 76 65 28 73 6f 63 6b | 2d 3e 72 65 61 64 42 75 |ove(sock|->readBu| |000046e0| 66 2c 20 62 75 66 66 65 | 72 2c 20 73 65 63 74 69 |f, buffe|r, secti| |000046f0| 6f 6e 29 3b 0d 09 09 0d | 09 09 62 75 66 66 65 72 |on);....|..buffer| |00004700| 09 09 09 09 3d 20 28 63 | 68 61 72 20 2a 29 20 62 |....= (c|har *) b| |00004710| 75 66 66 65 72 20 2b 20 | 73 65 63 74 69 6f 6e 3b |uffer + |section;| |00004720| 0d 09 09 73 6f 63 6b 2d | 3e 72 65 61 64 50 6f 73 |...sock-|>readPos| |00004730| 09 09 2b 3d 09 73 65 63 | 74 69 6f 6e 3b 0d 09 09 |..+=.sec|tion;...| |00004740| 73 6f 63 6b 2d 3e 76 61 | 6c 69 64 42 79 74 65 73 |sock->va|lidBytes| |00004750| 09 2d 3d 09 73 65 63 74 | 69 6f 6e 3b 0d 09 7d 0d |.-=.sect|ion;..}.| |00004760| 09 09 0d 09 72 65 74 75 | 72 6e 20 28 63 68 61 72 |....retu|rn (char| |00004770| 20 2a 29 20 62 75 66 66 | 65 72 2d 73 74 61 72 74 | *) buff|er-start| |00004780| 42 75 66 3b 09 09 0d 7d | 0d 0d 69 6e 74 20 55 6e |Buf;...}|..int Un| |00004790| 69 78 43 68 61 6e 6e 65 | 6c 3a 3a 57 72 69 74 65 |ixChanne|l::Write| |000047a0| 28 76 6f 69 64 20 2a 20 | 62 75 66 66 65 72 2c 20 |(void * |buffer, | |000047b0| 69 6e 74 20 6c 65 6e 29 | 0d 7b 09 0d 09 69 66 20 |int len)|.{...if | |000047c0| 28 21 73 6f 63 6b 20 7c | 7c 20 28 73 6f 63 6b 2d |(!sock ||| (sock-| |000047d0| 3e 73 74 61 74 75 73 20 | 26 20 53 4f 43 4b 5f 53 |>status |& SOCK_S| |000047e0| 54 41 54 55 53 5f 4e 4f | 57 52 49 54 45 29 29 0d |TATUS_NO|WRITE)).| |000047f0| 09 09 72 65 74 75 72 6e | 20 47 55 53 49 5f 65 72 |..return| GUSI_er| |00004800| 72 6f 72 28 45 53 48 55 | 54 44 4f 57 4e 29 3b 0d |ror(ESHU|TDOWN);.| |00004810| 0d 09 50 74 72 09 73 74 | 61 72 74 42 75 66 09 3d |..Ptr.st|artBuf.=| |00004820| 09 28 50 74 72 29 20 62 | 75 66 66 65 72 3b 0d 09 |.(Ptr) b|uffer;..| |00004830| 69 6e 74 09 61 76 61 69 | 6c 09 09 3d 09 73 6f 63 |int.avai|l..=.soc| |00004840| 6b 2d 3e 72 65 61 64 42 | 75 66 53 69 7a 65 20 2d |k->readB|ufSize -| |00004850| 20 73 6f 63 6b 2d 3e 76 | 61 6c 69 64 42 79 74 65 | sock->v|alidByte| |00004860| 73 3b 0d 09 69 6e 74 09 | 73 65 63 74 69 6f 6e 09 |s;..int.|section.| |00004870| 3d 09 61 76 61 69 6c 20 | 2d 20 73 6f 63 6b 2d 3e |=.avail |- sock->| |00004880| 72 65 61 64 50 6f 73 3b | 0d 09 09 0d 09 69 66 20 |readPos;|.....if | |00004890| 28 73 65 63 74 69 6f 6e | 20 3e 20 30 29 09 7b 0d |(section| > 0).{.| |000048a0| 09 09 69 66 20 28 73 65 | 63 74 69 6f 6e 20 3e 20 |..if (se|ction > | |000048b0| 6c 65 6e 29 0d 09 09 09 | 73 65 63 74 69 6f 6e 20 |len)....|section | |000048c0| 3d 20 6c 65 6e 3b 0d 09 | 09 09 0d 09 09 42 6c 6f |= len;..|.....Blo| |000048d0| 63 6b 4d 6f 76 65 28 62 | 75 66 66 65 72 2c 20 73 |ckMove(b|uffer, s| |000048e0| 6f 63 6b 2d 3e 72 65 61 | 64 42 75 66 2b 73 6f 63 |ock->rea|dBuf+soc| |000048f0| 6b 2d 3e 72 65 61 64 50 | 6f 73 2b 73 6f 63 6b 2d |k->readP|os+sock-| |00004900| 3e 76 61 6c 69 64 42 79 | 74 65 73 2c 20 73 65 63 |>validBy|tes, sec| |00004910| 74 69 6f 6e 29 3b 0d 09 | 09 0d 09 09 62 75 66 66 |tion);..|....buff| |00004920| 65 72 20 09 09 09 09 3d | 20 28 63 68 61 72 20 2a |er ....=| (char *| |00004930| 29 20 62 75 66 66 65 72 | 20 2b 20 73 65 63 74 69 |) buffer| + secti| |00004940| 6f 6e 3b 0d 09 09 73 6f | 63 6b 2d 3e 76 61 6c 69 |on;...so|ck->vali| |00004950| 64 42 79 74 65 73 09 2b | 3d 09 73 65 63 74 69 6f |dBytes.+|=.sectio| |00004960| 6e 3b 0d 09 09 6c 65 6e | 20 09 09 09 09 09 2d 3d |n;...len| .....-=| |00004970| 20 73 65 63 74 69 6f 6e | 3b 0d 09 09 61 76 61 69 | section|;...avai| |00004980| 6c 09 09 09 09 09 2d 3d | 09 73 65 63 74 69 6f 6e |l.....-=|.section| |00004990| 3b 0d 09 7d 0d 09 0d 09 | 69 66 20 28 6c 65 6e 20 |;..}....|if (len | |000049a0| 3e 20 30 20 26 26 20 61 | 76 61 69 6c 20 3e 20 30 |> 0 && a|vail > 0| |000049b0| 29 09 7b 0d 09 09 73 65 | 63 74 69 6f 6e 20 09 3d |).{...se|ction .=| |000049c0| 09 28 6c 65 6e 20 3e 20 | 61 76 61 69 6c 29 20 3f |.(len > |avail) ?| |000049d0| 20 61 76 61 69 6c 20 3a | 20 6c 65 6e 3b 0d 09 09 | avail :| len;...| |000049e0| 0d 09 09 42 6c 6f 63 6b | 4d 6f 76 65 28 62 75 66 |...Block|Move(buf| |000049f0| 66 65 72 2c 20 73 6f 63 | 6b 2d 3e 72 65 61 64 42 |fer, soc|k->readB| |00004a00| 75 66 2b 73 6f 63 6b 2d | 3e 72 65 61 64 50 6f 73 |uf+sock-|>readPos| |00004a10| 2d 61 76 61 69 6c 2c 20 | 73 65 63 74 69 6f 6e 29 |-avail, |section)| |00004a20| 3b 0d 09 09 0d 09 09 62 | 75 66 66 65 72 20 09 09 |;......b|uffer ..| |00004a30| 09 09 3d 20 28 63 68 61 | 72 20 2a 29 20 73 65 63 |..= (cha|r *) sec| |00004a40| 74 69 6f 6e 3b 0d 09 09 | 73 6f 63 6b 2d 3e 76 61 |tion;...|sock->va| |00004a50| 6c 69 64 42 79 74 65 73 | 09 2b 3d 09 73 65 63 74 |lidBytes|.+=.sect| |00004a60| 69 6f 6e 3b 0d 09 7d 0d | 09 09 0d 09 72 65 74 75 |ion;..}.|....retu| |00004a70| 72 6e 20 28 63 68 61 72 | 20 2a 29 20 62 75 66 66 |rn (char| *) buff| |00004a80| 65 72 2d 73 74 61 72 74 | 42 75 66 3b 09 09 0d 7d |er-start|Buf;...}| |00004a90| 0d 0d 69 6e 74 20 55 6e | 69 78 43 68 61 6e 6e 65 |..int Un|ixChanne| |00004aa0| 6c 3a 3a 53 65 6e 64 28 | 55 6e 69 78 43 68 61 6e |l::Send(|UnixChan| |00004ab0| 6e 65 6c 20 2a 20 66 72 | 6f 6d 2c 20 76 6f 69 64 |nel * fr|om, void| |00004ac0| 20 2a 20 62 75 66 66 65 | 72 2c 20 69 6e 74 20 6c | * buffe|r, int l| |00004ad0| 65 6e 29 0d 7b 0d 09 69 | 6e 74 20 6c 65 6e 67 74 |en).{..i|nt lengt| |00004ae0| 68 09 3d 09 73 69 7a 65 | 6f 66 28 55 6e 69 78 43 |h.=.size|of(UnixC| |00004af0| 68 61 6e 6e 65 6c 20 2a | 29 20 2b 20 73 69 7a 65 |hannel *|) + size| |00004b00| 6f 66 28 69 6e 74 29 20 | 2b 20 6c 65 6e 3b 0d 0d |of(int) |+ len;..| |00004b10| 09 69 66 20 28 73 6f 63 | 6b 2d 3e 70 65 65 72 20 |.if (soc|k->peer | |00004b20| 26 26 20 73 6f 63 6b 2d | 3e 70 65 65 72 20 21 3d |&& sock-|>peer !=| |00004b30| 20 66 72 6f 6d 29 0d 09 | 09 72 65 74 75 72 6e 20 | from)..|.return | |00004b40| 47 55 53 49 5f 65 72 72 | 6f 72 28 45 43 4f 4e 4e |GUSI_err|or(ECONN| |00004b50| 52 45 46 55 53 45 44 29 | 3b 0d 09 0d 09 69 66 20 |REFUSED)|;....if | |00004b60| 28 57 72 69 74 65 41 76 | 61 69 6c 28 29 20 3c 20 |(WriteAv|ail() < | |00004b70| 6c 65 6e 67 74 68 29 0d | 09 09 72 65 74 75 72 6e |length).|..return| |00004b80| 20 30 3b 0d 09 0d 09 57 | 72 69 74 65 28 26 66 72 | 0;....W|rite(&fr| |00004b90| 6f 6d 2c 20 73 69 7a 65 | 6f 66 28 55 6e 69 78 43 |om, size|of(UnixC| |00004ba0| 68 61 6e 6e 65 6c 20 2a | 29 29 3b 0d 09 57 72 69 |hannel *|));..Wri| |00004bb0| 74 65 28 26 6c 65 6e 2c | 20 73 69 7a 65 6f 66 28 |te(&len,| sizeof(| |00004bc0| 69 6e 74 29 29 3b 0d 09 | 0d 09 72 65 74 75 72 6e |int));..|..return| |00004bd0| 20 57 72 69 74 65 28 62 | 75 66 66 65 72 2c 20 6c | Write(b|uffer, l| |00004be0| 65 6e 29 3b 0d 7d 0d 0d | 69 6e 74 20 55 6e 69 78 |en);.}..|int Unix| |00004bf0| 43 68 61 6e 6e 65 6c 3a | 3a 52 65 61 64 41 76 61 |Channel:|:ReadAva| |00004c00| 69 6c 28 29 0d 7b 0d 09 | 69 66 20 28 73 6f 63 6b |il().{..|if (sock| |00004c10| 2d 3e 73 74 61 74 75 73 | 20 26 20 53 4f 43 4b 5f |->status| & SOCK_| |00004c20| 53 54 41 54 55 53 5f 4e | 4f 52 45 41 44 29 0d 09 |STATUS_N|OREAD)..| |00004c30| 09 72 65 74 75 72 6e 20 | 47 55 53 49 5f 65 72 72 |.return |GUSI_err| |00004c40| 6f 72 28 45 53 48 55 54 | 44 4f 57 4e 29 3b 0d 09 |or(ESHUT|DOWN);..| |00004c50| 09 0d 09 72 65 74 75 72 | 6e 20 73 6f 63 6b 2d 3e |...retur|n sock->| |00004c60| 76 61 6c 69 64 42 79 74 | 65 73 3b 0d 7d 0d 0d 69 |validByt|es;.}..i| |00004c70| 6e 74 20 55 6e 69 78 43 | 68 61 6e 6e 65 6c 3a 3a |nt UnixC|hannel::| |00004c80| 57 72 69 74 65 41 76 61 | 69 6c 28 29 0d 7b 0d 09 |WriteAva|il().{..| |00004c90| 69 66 20 28 21 73 6f 63 | 6b 20 7c 7c 20 28 73 6f |if (!soc|k || (so| |00004ca0| 63 6b 2d 3e 73 74 61 74 | 75 73 20 26 20 53 4f 43 |ck->stat|us & SOC| |00004cb0| 4b 5f 53 54 41 54 55 53 | 5f 4e 4f 57 52 49 54 45 |K_STATUS|_NOWRITE| |00004cc0| 29 29 0d 09 09 72 65 74 | 75 72 6e 20 47 55 53 49 |))...ret|urn GUSI| |00004cd0| 5f 65 72 72 6f 72 28 45 | 53 48 55 54 44 4f 57 4e |_error(E|SHUTDOWN| |00004ce0| 29 3b 0d 09 09 0d 09 72 | 65 74 75 72 6e 20 73 6f |);.....r|eturn so| |00004cf0| 63 6b 2d 3e 72 65 61 64 | 42 75 66 53 69 7a 65 20 |ck->read|BufSize | |00004d00| 2d 20 73 6f 63 6b 2d 3e | 76 61 6c 69 64 42 79 74 |- sock->|validByt| |00004d10| 65 73 3b 0d 7d 0d 0d 69 | 6e 74 20 55 6e 69 78 43 |es;.}..i|nt UnixC| |00004d20| 68 61 6e 6e 65 6c 3a 3a | 42 75 66 53 69 7a 65 28 |hannel::|BufSize(| |00004d30| 29 0d 7b 0d 09 72 65 74 | 75 72 6e 20 73 6f 63 6b |).{..ret|urn sock| |00004d40| 2d 3e 72 65 61 64 42 75 | 66 53 69 7a 65 3b 0d 7d |->readBu|fSize;.}| |00004d50| 0d 0d 76 6f 69 64 20 55 | 6e 69 78 43 68 61 6e 6e |..void U|nixChann| |00004d60| 65 6c 3a 3a 53 68 75 74 | 44 6f 77 6e 28 69 6e 74 |el::Shut|Down(int| |00004d70| 20 68 6f 77 29 0d 7b 0d | 09 73 77 69 74 63 68 28 | how).{.|.switch(| |00004d80| 68 6f 77 29 20 7b 0d 09 | 63 61 73 65 20 30 20 3a |how) {..|case 0 :| |00004d90| 20 0d 09 09 73 6f 63 6b | 2d 3e 73 74 61 74 75 73 | ...sock|->status| |00004da0| 20 7c 3d 20 53 4f 43 4b | 5f 53 54 41 54 55 53 5f | |= SOCK|_STATUS_| |00004db0| 4e 4f 52 45 41 44 3b 0d | 09 09 62 72 65 61 6b 3b |NOREAD;.|..break;| |00004dc0| 0d 09 63 61 73 65 20 31 | 20 3a 20 0d 09 09 73 6f |..case 1| : ...so| |00004dd0| 63 6b 2d 3e 73 74 61 74 | 75 73 20 7c 3d 20 53 4f |ck->stat|us |= SO| |00004de0| 43 4b 5f 53 54 41 54 55 | 53 5f 4e 4f 57 52 49 54 |CK_STATU|S_NOWRIT| |00004df0| 45 3b 0d 09 09 62 72 65 | 61 6b 3b 0d 09 63 61 73 |E;...bre|ak;..cas| |00004e00| 65 20 32 20 3a 0d 09 09 | 73 6f 63 6b 2d 3e 73 74 |e 2 :...|sock->st| |00004e10| 61 74 75 73 20 7c 3d 20 | 53 4f 43 4b 5f 53 54 41 |atus |= |SOCK_STA| |00004e20| 54 55 53 5f 4e 4f 52 45 | 41 44 20 7c 20 53 4f 43 |TUS_NORE|AD | SOC| |00004e30| 4b 5f 53 54 41 54 55 53 | 5f 4e 4f 57 52 49 54 45 |K_STATUS|_NOWRITE| |00004e40| 3b 0d 09 7d 0d 7d 0d 0d | 76 6f 69 64 20 55 6e 69 |;..}.}..|void Uni| |00004e50| 78 43 68 61 6e 6e 65 6c | 3a 3a 44 69 73 63 61 72 |xChannel|::Discar| |00004e60| 64 52 65 61 64 28 69 6e | 74 20 6c 65 6e 29 0d 7b |dRead(in|t len).{| |00004e70| 0d 09 69 66 20 28 73 6f | 63 6b 2d 3e 76 61 6c 69 |..if (so|ck->vali| |00004e80| 64 42 79 74 65 73 20 3c | 3d 20 6c 65 6e 29 09 7b |dBytes <|= len).{| |00004e90| 0d 09 09 73 6f 63 6b 2d | 3e 76 61 6c 69 64 42 79 |...sock-|>validBy| |00004ea0| 74 65 73 09 3d 09 30 3b | 0d 09 09 73 6f 63 6b 2d |tes.=.0;|...sock-| |00004eb0| 3e 72 65 61 64 50 6f 73 | 09 09 3d 09 30 3b 0d 09 |>readPos|..=.0;..| |00004ec0| 7d 20 65 6c 73 65 20 7b | 0d 09 09 73 6f 63 6b 2d |} else {|...sock-| |00004ed0| 3e 76 61 6c 69 64 42 79 | 74 65 73 09 2d 3d 09 6c |>validBy|tes.-=.l| |00004ee0| 65 6e 3b 0d 09 09 73 6f | 63 6b 2d 3e 72 65 61 64 |en;...so|ck->read| |00004ef0| 50 6f 73 09 09 3d 20 28 | 73 6f 63 6b 2d 3e 72 65 |Pos..= (|sock->re| |00004f00| 61 64 50 6f 73 2b 6c 65 | 6e 29 20 25 20 73 6f 63 |adPos+le|n) % soc| |00004f10| 6b 2d 3e 72 65 61 64 42 | 75 66 53 69 7a 65 3b 0d |k->readB|ufSize;.| |00004f20| 09 7d 0d 7d 0d 0d 76 6f | 69 64 20 55 6e 69 78 43 |.}.}..vo|id UnixC| |00004f30| 68 61 6e 6e 65 6c 3a 3a | 44 69 73 63 6f 6e 6e 65 |hannel::|Disconne| |00004f40| 63 74 28 29 0d 7b 0d 09 | 69 66 20 28 73 6f 63 6b |ct().{..|if (sock| |00004f50| 29 20 7b 0d 09 09 73 6f | 63 6b 2d 3e 70 65 65 72 |) {...so|ck->peer| |00004f60| 09 3d 09 6e 69 6c 3b 0d | 09 09 73 6f 63 6b 2d 3e |.=.nil;.|..sock->| |00004f70| 73 74 61 74 65 09 3d 09 | 53 4f 43 4b 5f 53 54 41 |state.=.|SOCK_STA| |00004f80| 54 45 5f 55 4e 43 4f 4e | 4e 45 43 54 45 44 3b 0d |TE_UNCON|NECTED;.| |00004f90| 09 7d 0d 7d 0d 0d 69 6e | 74 20 55 6e 69 78 43 68 |.}.}..in|t UnixCh| |00004fa0| 61 6e 6e 65 6c 3a 3a 47 | 55 53 49 5f 65 72 72 6f |annel::G|USI_erro| |00004fb0| 72 28 69 6e 74 20 65 72 | 72 29 0d 7b 0d 09 65 72 |r(int er|r).{..er| |00004fc0| 72 6e 6f 09 3d 09 65 72 | 72 3b 0d 0d 09 72 65 74 |rno.=.er|r;...ret| |00004fd0| 75 72 6e 20 2d 31 3b 0d | 7d 0d 0d 55 6e 69 78 53 |urn -1;.|}..UnixS| |00004fe0| 6f 63 6b 65 74 41 64 64 | 72 20 26 20 55 6e 69 78 |ocketAdd|r & Unix| |00004ff0| 43 68 61 6e 6e 65 6c 3a | 3a 41 64 64 72 65 73 73 |Channel:|:Address| |00005000| 28 29 0d 7b 0d 09 72 65 | 74 75 72 6e 20 61 64 64 |().{..re|turn add| |00005010| 72 65 73 73 3b 0d 7d 0d | 0d 2f 2a 2a 2a 2a 2a 2a |ress;.}.|./******| |00005020| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00005030| 2a 20 55 6e 69 78 43 68 | 61 6e 6e 65 6c 32 20 6d |* UnixCh|annel2 m| |00005040| 65 6d 62 65 72 73 20 2a | 2a 2a 2a 2a 2a 2a 2a 2a |embers *|********| |00005050| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2f |********|*******/| |00005060| 0d 0d 55 6e 69 78 43 68 | 61 6e 6e 65 6c 32 3a 3a |..UnixCh|annel2::| |00005070| 55 6e 69 78 43 68 61 6e | 6e 65 6c 32 28 55 6e 69 |UnixChan|nel2(Uni| |00005080| 78 53 6f 63 6b 65 74 20 | 2a 20 6f 77 6e 65 72 29 |xSocket |* owner)| |00005090| 0d 09 3a 09 55 6e 69 78 | 43 68 61 6e 6e 65 6c 28 |..:.Unix|Channel(| |000050a0| 6f 77 6e 65 72 29 0d 7b | 0d 7d 0d 0d 69 6e 74 20 |owner).{|.}..int | |000050b0| 55 6e 69 78 43 68 61 6e | 6e 65 6c 32 3a 3a 56 65 |UnixChan|nel2::Ve| |000050c0| 72 73 69 6f 6e 28 29 0d | 7b 0d 09 72 65 74 75 72 |rsion().|{..retur| |000050d0| 6e 20 32 3b 0d 7d 0d 0d | 76 6f 69 64 20 55 6e 69 |n 2;.}..|void Uni| |000050e0| 78 43 68 61 6e 6e 65 6c | 32 3a 3a 4f 72 70 68 61 |xChannel|2::Orpha| |000050f0| 6e 28 29 0d 7b 0d 09 2f | 2f 20 53 65 76 65 72 20 |n().{../|/ Sever | |00005100| 74 69 65 73 20 74 6f 20 | 6f 77 6e 65 72 0d 09 0d |ties to |owner...| |00005110| 09 73 6f 63 6b 2d 3e 63 | 68 61 6e 09 3d 09 6e 69 |.sock->c|han.=.ni| |00005120| 6c 3b 0d 09 73 6f 63 6b | 20 09 09 09 3d 20 09 6e |l;..sock| ...= .n| |00005130| 69 6c 3b 0d 7d 0d 0d 76 | 6f 69 64 20 55 6e 69 78 |il;.}..v|oid Unix| |00005140| 43 68 61 6e 6e 65 6c 32 | 3a 3a 41 62 6f 72 74 43 |Channel2|::AbortC| |00005150| 6f 6e 6e 65 63 74 28 55 | 6e 69 78 43 68 61 6e 6e |onnect(U|nixChann| |00005160| 65 6c 20 2a 20 63 68 29 | 0d 7b 0d 09 55 6e 69 78 |el * ch)|.{..Unix| |00005170| 43 68 61 6e 6e 65 6c 09 | 2a 20 70 72 65 76 20 3d |Channel.|* prev =| |00005180| 20 6e 69 6c 3b 0d 09 0d | 09 66 6f 72 20 28 55 6e | nil;...|.for (Un| |00005190| 69 78 43 68 61 6e 6e 65 | 6c 20 2a 20 63 68 61 6e |ixChanne|l * chan| |000051a0| 20 3d 20 73 6f 63 6b 2d | 3e 66 69 72 73 74 4c 69 | = sock-|>firstLi| |000051b0| 73 74 65 6e 65 72 3b 20 | 63 68 61 6e 3b 20 63 68 |stener; |chan; ch| |000051c0| 61 6e 20 3d 20 63 68 61 | 6e 2d 3e 6e 65 78 74 4c |an = cha|n->nextL| |000051d0| 69 73 74 65 6e 65 72 29 | 20 7b 0d 09 09 69 66 20 |istener)| {...if | |000051e0| 28 63 68 61 6e 20 3d 3d | 20 63 68 29 09 7b 09 2f |(chan ==| ch).{./| |000051f0| 2f 20 47 6f 74 20 69 74 | 20 21 0d 09 09 09 69 66 |/ Got it| !....if| |00005200| 20 28 70 72 65 76 29 0d | 09 09 09 09 70 72 65 76 | (prev).|....prev| |00005210| 2d 3e 6e 65 78 74 4c 69 | 73 74 65 6e 65 72 09 3d |->nextLi|stener.=| |00005220| 09 63 68 61 6e 2d 3e 6e | 65 78 74 4c 69 73 74 65 |.chan->n|extListe| |00005230| 6e 65 72 3b 0d 09 09 09 | 65 6c 73 65 0d 09 09 09 |ner;....|else....| |00005240| 09 73 6f 63 6b 2d 3e 66 | 69 72 73 74 4c 69 73 74 |.sock->f|irstList| |00005250| 65 6e 65 72 09 3d 09 63 | 68 61 6e 2d 3e 6e 65 78 |ener.=.c|han->nex| |00005260| 74 4c 69 73 74 65 6e 65 | 72 3b 0d 09 09 09 0d 09 |tListene|r;......| |00005270| 09 09 69 66 20 28 21 63 | 68 61 6e 2d 3e 6e 65 78 |..if (!c|han->nex| |00005280| 74 4c 69 73 74 65 6e 65 | 72 29 0d 09 09 09 09 73 |tListene|r).....s| |00005290| 6f 63 6b 2d 3e 6c 61 73 | 74 4c 69 73 74 65 6e 65 |ock->las|tListene| |000052a0| 72 09 3d 09 70 72 65 76 | 3b 0d 09 09 09 0d 09 09 |r.=.prev|;.......| |000052b0| 09 69 66 20 28 21 2d 2d | 73 6f 63 6b 2d 3e 63 75 |.if (!--|sock->cu| |000052c0| 72 4c 69 73 74 65 6e 65 | 72 29 0d 09 09 09 09 73 |rListene|r).....s| |000052d0| 6f 63 6b 2d 3e 73 74 61 | 74 65 20 3d 20 53 4f 43 |ock->sta|te = SOC| |000052e0| 4b 5f 53 54 41 54 45 5f | 4c 49 53 54 45 4e 49 4e |K_STATE_|LISTENIN| |000052f0| 47 3b 0d 09 09 09 0d 09 | 09 09 62 72 65 61 6b 3b |G;......|..break;| |00005300| 0d 09 09 7d 0d 09 09 70 | 72 65 76 20 3d 20 63 68 |...}...p|rev = ch| |00005310| 61 6e 3b 0d 09 7d 0d 7d | 0d 0d 2f 2a 2a 2a 2a 2a |an;..}.}|../*****| |00005320| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00005330| 20 55 6e 69 78 53 6f 63 | 6b 65 74 49 44 20 6d 65 | UnixSoc|ketID me| |00005340| 6d 62 65 72 73 20 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |mbers **|********| |00005350| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2f 0d 0d 55 |********|****/..U| |00005360| 6e 69 78 53 6f 63 6b 65 | 74 49 44 3a 3a 55 6e 69 |nixSocke|tID::Uni| |00005370| 78 53 6f 63 6b 65 74 49 | 44 28 55 6e 69 78 43 68 |xSocketI|D(UnixCh| |00005380| 61 6e 6e 65 6c 20 2a 20 | 63 68 29 0d 09 3a 20 63 |annel * |ch)..: c| |00005390| 68 61 6e 28 63 68 29 0d | 7b 0d 09 73 68 6f 72 74 |han(ch).|{..short| |000053a0| 09 6e 65 74 3b 0d 09 73 | 68 6f 72 74 20 6e 6f 64 |.net;..s|hort nod| |000053b0| 65 3b 0d 09 0d 09 41 70 | 70 6c 65 54 61 6c 6b 49 |e;....Ap|pleTalkI| |000053c0| 64 65 6e 74 69 74 79 28 | 6e 65 74 2c 20 6e 6f 64 |dentity(|net, nod| |000053d0| 65 29 3b 0d 09 0d 09 6d | 61 63 68 69 6e 65 2e 61 |e);....m|achine.a| |000053e0| 4e 65 74 09 3d 09 6e 65 | 74 3b 0d 09 6d 61 63 68 |Net.=.ne|t;..mach| |000053f0| 69 6e 65 2e 61 4e 6f 64 | 65 09 3d 09 6e 6f 64 65 |ine.aNod|e.=.node| |00005400| 3b 0d 09 6d 61 63 68 69 | 6e 65 2e 61 53 6f 63 6b |;..machi|ne.aSock| |00005410| 65 74 3d 09 30 3b 0d 09 | 0d 09 69 66 20 28 21 68 |et=.0;..|..if (!h| |00005420| 61 73 50 72 6f 63 65 73 | 73 4d 67 72 20 7c 7c 20 |asProces|sMgr || | |00005430| 47 65 74 43 75 72 72 65 | 6e 74 50 72 6f 63 65 73 |GetCurre|ntProces| |00005440| 73 28 26 70 72 6f 63 65 | 73 73 29 29 09 7b 0d 09 |s(&proce|ss)).{..| |00005450| 09 70 72 6f 63 65 73 73 | 2e 68 69 67 68 4c 6f 6e |.process|.highLon| |00005460| 67 4f 66 50 53 4e 20 3d | 20 6b 4e 6f 50 72 6f 63 |gOfPSN =| kNoProc| |00005470| 65 73 73 3b 0d 09 09 70 | 72 6f 63 65 73 73 2e 6c |ess;...p|rocess.l| |00005480| 6f 77 4c 6f 6e 67 4f 66 | 50 53 4e 20 3d 20 6b 4e |owLongOf|PSN = kN| |00005490| 6f 50 72 6f 63 65 73 73 | 3b 0d 09 7d 09 0d 7d 0d |oProcess|;..}..}.| |000054a0| 0d 42 6f 6f 6c 65 61 6e | 20 55 6e 69 78 53 6f 63 |.Boolean| UnixSoc| |000054b0| 6b 65 74 49 44 3a 3a 56 | 61 6c 69 64 61 74 65 28 |ketID::V|alidate(| |000054c0| 29 0d 7b 0d 09 55 6e 69 | 78 53 6f 63 6b 65 74 49 |).{..Uni|xSocketI| |000054d0| 44 09 6d 65 28 6e 69 6c | 29 3b 0d 09 50 72 6f 63 |D.me(nil|);..Proc| |000054e0| 65 73 73 49 6e 66 6f 52 | 65 63 09 69 6e 66 6f 3b |essInfoR|ec.info;| |000054f0| 0d 09 0d 09 69 66 20 28 | 6d 65 6d 63 6d 70 28 26 |....if (|memcmp(&| |00005500| 6d 61 63 68 69 6e 65 2c | 20 26 6d 65 2e 6d 61 63 |machine,| &me.mac| |00005510| 68 69 6e 65 2c 20 73 69 | 7a 65 6f 66 28 41 64 64 |hine, si|zeof(Add| |00005520| 72 42 6c 6f 63 6b 29 29 | 29 0d 09 09 72 65 74 75 |rBlock))|)...retu| |00005530| 72 6e 20 66 61 6c 73 65 | 3b 0d 09 09 0d 09 69 66 |rn false|;.....if| |00005540| 20 28 21 68 61 73 50 72 | 6f 63 65 73 73 4d 67 72 | (!hasPr|ocessMgr| |00005550| 29 0d 09 09 72 65 74 75 | 72 6e 20 28 21 70 72 6f |)...retu|rn (!pro| |00005560| 63 65 73 73 2e 68 69 67 | 68 4c 6f 6e 67 4f 66 50 |cess.hig|hLongOfP| |00005570| 53 4e 20 26 26 20 21 70 | 72 6f 63 65 73 73 2e 6c |SN && !p|rocess.l| |00005580| 6f 77 4c 6f 6e 67 4f 66 | 50 53 4e 29 3b 0d 09 0d |owLongOf|PSN);...| |00005590| 09 69 6e 66 6f 2e 70 72 | 6f 63 65 73 73 49 6e 66 |.info.pr|ocessInf| |000055a0| 6f 4c 65 6e 67 74 68 09 | 3d 09 73 69 7a 65 6f 66 |oLength.|=.sizeof| |000055b0| 28 50 72 6f 63 65 73 73 | 49 6e 66 6f 52 65 63 29 |(Process|InfoRec)| |000055c0| 3b 0d 09 69 6e 66 6f 2e | 70 72 6f 63 65 73 73 4e |;..info.|processN| |000055d0| 61 6d 65 09 09 09 3d 09 | 6e 69 6c 3b 0d 09 69 6e |ame...=.|nil;..in| |000055e0| 66 6f 2e 70 72 6f 63 65 | 73 73 41 70 70 53 70 65 |fo.proce|ssAppSpe| |000055f0| 63 09 09 3d 09 6e 69 6c | 3b 0d 09 0d 09 72 65 74 |c..=.nil|;....ret| |00005600| 75 72 6e 20 21 47 65 74 | 50 72 6f 63 65 73 73 49 |urn !Get|ProcessI| |00005610| 6e 66 6f 72 6d 61 74 69 | 6f 6e 28 26 70 72 6f 63 |nformati|on(&proc| |00005620| 65 73 73 2c 20 26 69 6e | 66 6f 29 3b 0d 7d 0d 0d |ess, &in|fo);.}..| |00005630| 2f 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |/*******|********| |00005640| 2a 2a 2a 2a 2a 2a 20 55 | 6e 69 78 53 6f 63 6b 65 |****** U|nixSocke| |00005650| 74 44 6f 6d 61 69 6e 20 | 6d 65 6d 62 65 72 20 2a |tDomain |member *| |00005660| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |00005670| 2a 2a 2a 2a 2a 2f 0d 0d | 53 6f 63 6b 65 74 20 2a |*****/..|Socket *| |00005680| 20 55 6e 69 78 53 6f 63 | 6b 65 74 44 6f 6d 61 69 | UnixSoc|ketDomai| |00005690| 6e 3a 3a 73 6f 63 6b 65 | 74 28 69 6e 74 20 74 79 |n::socke|t(int ty| |000056a0| 70 65 2c 20 73 68 6f 72 | 74 29 0d 7b 0d 09 55 6e |pe, shor|t).{..Un| |000056b0| 69 78 53 6f 63 6b 65 74 | 20 2a 20 73 6f 63 6b 09 |ixSocket| * sock.| |000056c0| 3d 09 6e 69 6c 3b 0d 09 | 0d 09 73 77 69 74 63 68 |=.nil;..|..switch| |000056d0| 20 28 74 79 70 65 29 09 | 7b 0d 09 63 61 73 65 20 | (type).|{..case | |000056e0| 53 4f 43 4b 5f 53 54 52 | 45 41 4d 3a 0d 09 09 73 |SOCK_STR|EAM:...s| |000056f0| 6f 63 6b 20 3d 20 6e 65 | 77 20 55 6e 69 78 53 74 |ock = ne|w UnixSt| |00005700| 72 65 61 6d 53 6f 63 6b | 65 74 28 29 3b 0d 09 09 |reamSock|et();...| |00005710| 62 72 65 61 6b 3b 0d 09 | 63 61 73 65 20 53 4f 43 |break;..|case SOC| |00005720| 4b 5f 44 47 52 41 4d 3a | 0d 09 09 73 6f 63 6b 20 |K_DGRAM:|...sock | |00005730| 3d 20 6e 65 77 20 55 6e | 69 78 44 67 72 61 6d 53 |= new Un|ixDgramS| |00005740| 6f 63 6b 65 74 28 29 3b | 0d 09 09 62 72 65 61 6b |ocket();|...break| |00005750| 3b 0d 09 64 65 66 61 75 | 6c 74 3a 0d 09 09 47 55 |;..defau|lt:...GU| |00005760| 53 49 5f 65 72 72 6f 72 | 28 45 53 4f 43 4b 54 4e |SI_error|(ESOCKTN| |00005770| 4f 53 55 50 50 4f 52 54 | 29 3b 0d 09 7d 09 0d 09 |OSUPPORT|);..}...| |00005780| 0d 09 69 66 20 28 73 6f | 63 6b 20 26 26 20 65 72 |..if (so|ck && er| |00005790| 72 6e 6f 29 09 7b 0d 09 | 09 64 65 6c 65 74 65 20 |rno).{..|.delete | |000057a0| 73 6f 63 6b 3b 0d 09 09 | 0d 09 09 72 65 74 75 72 |sock;...|...retur| |000057b0| 6e 20 6e 69 6c 3b 0d 09 | 7d 20 65 6c 73 65 0d 09 |n nil;..|} else..| |000057c0| 09 72 65 74 75 72 6e 20 | 73 6f 63 6b 3b 0d 7d 0d |.return |sock;.}.| |000057d0| 0d 69 6e 74 20 55 6e 69 | 78 53 6f 63 6b 65 74 44 |.int Uni|xSocketD| |000057e0| 6f 6d 61 69 6e 3a 3a 63 | 68 6f 6f 73 65 28 69 6e |omain::c|hoose(in| |000057f0| 74 2c 20 63 68 61 72 20 | 2a 20 70 72 6f 6d 70 74 |t, char |* prompt| |00005800| 2c 20 76 6f 69 64 20 2a | 2c 20 69 6e 74 20 66 6c |, void *|, int fl| |00005810| 61 67 73 2c 20 76 6f 69 | 64 20 2a 20 6e 61 6d 65 |ags, voi|d * name| |00005820| 2c 20 69 6e 74 20 2a 20 | 6e 61 6d 65 6c 65 6e 29 |, int * |namelen)| |00005830| 0d 7b 0d 09 73 74 72 75 | 63 74 20 73 6f 63 6b 61 |.{..stru|ct socka| |00005840| 64 64 72 5f 75 6e 20 2a | 09 61 64 64 72 20 3d 20 |ddr_un *|.addr = | |00005850| 28 73 6f 63 6b 61 64 64 | 72 5f 75 6e 20 2a 29 20 |(sockadd|r_un *) | |00005860| 6e 61 6d 65 3b 0d 09 73 | 61 5f 63 6f 6e 73 74 72 |name;..s|a_constr| |00005870| 5f 66 69 6c 65 09 09 09 | 63 6f 6e 73 74 72 3b 0d |_file...|constr;.| |00005880| 09 0d 09 61 64 64 72 2d | 3e 73 75 6e 5f 66 61 6d |...addr-|>sun_fam| |00005890| 69 6c 79 09 3d 20 41 46 | 5f 55 4e 49 58 3b 0d 0d |ily.= AF|_UNIX;..| |000058a0| 09 63 6f 6e 73 74 72 2e | 6e 75 6d 54 79 70 65 73 |.constr.|numTypes| |000058b0| 09 3d 09 31 3b 0d 09 63 | 6f 6e 73 74 72 2e 74 79 |.=.1;..c|onstr.ty| |000058c0| 70 65 73 5b 30 5d 09 3d | 09 27 b7 4f 43 4b 27 3b |pes[0].=|.'.OCK';| |000058d0| 0d 09 0d 09 2a 6e 61 6d | 65 6c 65 6e 20 2d 3d 20 |....*nam|elen -= | |000058e0| 32 3b 0d 09 69 66 20 28 | 46 69 6c 65 53 6f 63 6b |2;..if (|FileSock| |000058f0| 65 74 73 2e 63 68 6f 6f | 73 65 28 30 2c 20 70 72 |ets.choo|se(0, pr| |00005900| 6f 6d 70 74 2c 20 26 63 | 6f 6e 73 74 72 2c 20 66 |ompt, &c|onstr, f| |00005910| 6c 61 67 73 2c 20 61 64 | 64 72 2d 3e 73 75 6e 5f |lags, ad|dr->sun_| |00005920| 70 61 74 68 2c 20 6e 61 | 6d 65 6c 65 6e 29 29 0d |path, na|melen)).| |00005930| 09 09 72 65 74 75 72 6e | 20 2d 31 3b 0d 09 0d 09 |..return| -1;....| |00005940| 2a 6e 61 6d 65 6c 65 6e | 20 2b 3d 20 32 3b 0d 09 |*namelen| += 2;..| |00005950| 0d 09 72 65 74 75 72 6e | 20 30 3b 0d 7d 0d 0d 0d |..return| 0;.}...| |00005960| 2f 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |/*******|********| |00005970| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 20 4e 61 6d 65 20 |********|** Name | |00005980| 63 6f 6e 76 65 72 73 69 | 6f 6e 73 20 2a 2a 2a 2a |conversi|ons ****| |00005990| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 2a 2a |********|********| |000059a0| 2a 2a 2a 2a 2a 2f 0d 0d | 73 74 61 74 69 63 20 63 |*****/..|static c| |000059b0| 68 61 72 09 09 09 09 09 | 63 61 6e 6f 6e 50 61 74 |har.....|canonPat| |000059c0| 68 5b 31 32 30 5d 3b 0d | 73 74 61 74 69 63 20 55 |h[120];.|static U| |000059d0| 6e 69 78 53 6f 63 6b 65 | 74 41 64 64 72 09 63 61 |nixSocke|tAddr.ca| |000059e0| 6e 6f 6e 41 64 64 72 3b | 0d 0d 73 74 61 74 69 63 |nonAddr;|..static| |000059f0| 20 55 6e 69 78 53 6f 63 | 6b 65 74 41 64 64 72 20 | UnixSoc|ketAddr | |00005a00| 2a 20 43 61 6e 6f 6e 69 | 7a 65 4e 61 6d 65 28 76 |* Canoni|zeName(v| |00005a10| 6f 69 64 20 2a 20 6e 61 | 6d 65 2c 20 69 6e 74 20 |oid * na|me, int | |00005a20| 6c 65 6e 29 0d 7b 0d 09 | 73 74 72 75 63 74 20 73 |len).{..|struct s| |00005a30| 6f 63 6b 61 64 64 72 5f | 75 6e 20 2a 09 61 64 64 |ockaddr_|un *.add| |00005a40| 72 20 3d 20 28 73 6f 63 | 6b 61 64 64 72 5f 75 6e |r = (soc|kaddr_un| |00005a50| 20 2a 29 20 6e 61 6d 65 | 3b 0d 09 0d 09 69 66 20 | *) name|;....if | |00005a60| 28 21 6e 61 6d 65 20 7c | 7c 20 21 6c 65 6e 20 7c |(!name ||| !len || |00005a70| 7c 20 61 64 64 72 2d 3e | 73 75 6e 5f 66 61 6d 69 || addr->|sun_fami| |00005a80| 6c 79 20 21 3d 20 41 46 | 5f 55 4e 49 58 29 09 7b |ly != AF|_UNIX).{| |00005a90| 0d 09 09 47 55 53 49 5f | 65 72 72 6f 72 28 45 41 |...GUSI_|error(EA| |00005aa0| 46 4e 4f 53 55 50 50 4f | 52 54 29 3b 0d 09 09 0d |FNOSUPPO|RT);....| |00005ab0| 09 09 72 65 74 75 72 6e | 20 6e 69 6c 3b 0d 09 7d |..return| nil;..}| |00005ac0| 0d 09 0d 09 6c 65 6e 20 | 2d 3d 20 32 3b 0d 09 6d |....len |-= 2;..m| |00005ad0| 65 6d 63 70 79 28 63 61 | 6e 6f 6e 50 61 74 68 2c |emcpy(ca|nonPath,| |00005ae0| 20 61 64 64 72 2d 3e 73 | 75 6e 5f 70 61 74 68 2c | addr->s|un_path,| |00005af0| 20 6c 65 6e 29 3b 0d 09 | 0d 09 63 61 6e 6f 6e 50 | len);..|..canonP| |00005b00| 61 74 68 5b 6c 65 6e 5d | 20 3d 20 09 30 3b 0d 09 |ath[len]| = .0;..| |00005b10| 63 61 6e 6f 6e 41 64 64 | 72 09 09 3d 09 54 46 69 |canonAdd|r..=.TFi| |00005b20| 6c 65 53 70 65 63 28 63 | 61 6e 6f 6e 50 61 74 68 |leSpec(c|anonPath| |00005b30| 29 3b 0d 09 0d 09 69 66 | 20 28 63 61 6e 6f 6e 41 |);....if| (canonA| |00005b40| 64 64 72 2e 45 72 72 6f | 72 28 29 29 0d 09 09 72 |ddr.Erro|r())...r| |00005b50| 65 74 75 72 6e 20 6e 69 | 6c 3b 0d 09 65 6c 73 65 |eturn ni|l;..else| |00005b60| 0d 09 09 63 61 6e 6f 6e | 41 64 64 72 2e 76 61 6c |...canon|Addr.val| |00005b70| 69 64 09 3d 09 74 72 75 | 65 3b 0d 09 09 0d 09 72 |id.=.tru|e;.....r| |00005b80| 65 74 75 72 6e 20 26 63 | 61 6e 6f 6e 41 64 64 72 |eturn &c|anonAddr| |00005b90| 3b 0d 7d 0d 0d 73 74 61 | 74 69 63 20 76 6f 69 64 |;.}..sta|tic void| |00005ba0| 20 55 6e 63 61 6e 6f 6e | 69 7a 65 4e 61 6d 65 28 | Uncanon|izeName(| |00005bb0| 55 6e 69 78 53 6f 63 6b | 65 74 41 64 64 72 20 26 |UnixSock|etAddr &| |00005bc0| 20 6e 61 6d 65 2c 20 76 | 6f 69 64 20 2a 20 61 64 | name, v|oid * ad| |00005bd0| 64 72 2c 20 69 6e 74 20 | 2a 20 61 64 64 72 6c 65 |dr, int |* addrle| |00005be0| 6e 29 0d 7b 0d 09 73 74 | 72 75 63 74 20 73 6f 63 |n).{..st|ruct soc| |00005bf0| 6b 61 64 64 72 5f 75 6e | 20 2a 09 75 61 64 64 72 |kaddr_un| *.uaddr| |00005c00| 20 3d 20 28 73 6f 63 6b | 61 64 64 72 5f 75 6e 20 | = (sock|addr_un | |00005c10| 2a 29 20 61 64 64 72 3b | 0d 09 63 68 61 72 09 2a |*) addr;|..char.*| |00005c20| 20 09 09 09 09 09 70 61 | 74 68 09 3d 09 6e 61 6d | .....pa|th.=.nam| |00005c30| 65 2e 46 75 6c 6c 50 61 | 74 68 28 29 3b 0d 09 63 |e.FullPa|th();..c| |00005c40| 68 61 72 20 09 2a 20 09 | 09 09 09 09 65 6e 64 3b |har .* .|....end;| |00005c50| 0d 09 0d 09 69 66 20 28 | 21 61 64 64 72 20 7c 7c |....if (|!addr ||| |00005c60| 20 2a 61 64 64 72 6c 65 | 6e 20 3c 20 73 69 7a 65 | *addrle|n < size| |00005c70| 6f 66 28 73 68 6f 72 74 | 29 29 09 7b 0d 09 09 69 |of(short|)).{...i| |00005c80| 66 20 28 61 64 64 72 6c | 65 6e 29 0d 09 09 09 2a |f (addrl|en)....*| |00005c90| 61 64 64 72 6c 65 6e 20 | 3d 20 30 3b 0d 09 09 0d |addrlen |= 0;....| |00005ca0| 09 09 72 65 74 75 72 6e | 3b 0d 09 7d 0d 09 0d 09 |..return|;..}....| |00005cb0| 2a 61 64 64 72 6c 65 6e | 20 09 09 09 2d 3d 20 32 |*addrlen| ...-= 2| |00005cc0| 3b 0d 09 75 61 64 64 72 | 2d 3e 73 75 6e 5f 66 61 |;..uaddr|->sun_fa| |00005cd0| 6d 69 6c 79 20 3d 20 09 | 41 46 5f 55 4e 49 58 3b |mily = .|AF_UNIX;| |00005ce0| 0d 09 0d 09 69 66 20 28 | 65 6e 64 20 3d 20 28 63 |....if (|end = (c| |00005cf0| 68 61 72 20 2a 29 20 6d | 65 6d 63 63 70 79 28 75 |har *) m|emccpy(u| |00005d00| 61 64 64 72 2d 3e 73 75 | 6e 5f 70 61 74 68 2c 20 |addr->su|n_path, | |00005d10| 70 61 74 68 2c 20 30 2c | 20 2a 61 64 64 72 6c 65 |path, 0,| *addrle| |00005d20| 6e 29 29 0d 09 09 2a 61 | 64 64 72 6c 65 6e 20 3d |n))...*a|ddrlen =| |00005d30| 20 65 6e 64 2d 75 61 64 | 64 72 2d 3e 73 75 6e 5f | end-uad|dr->sun_| |00005d40| 70 61 74 68 2d 31 3b 0d | 09 0d 09 2a 61 64 64 72 |path-1;.|...*addr| |00005d50| 6c 65 6e 20 09 09 09 2b | 3d 20 09 32 3b 0d 7d 0d |len ...+|= .2;.}.| |00005d60| 0d 73 74 61 74 69 63 20 | 55 6e 69 78 43 68 61 6e |.static |UnixChan| |00005d70| 6e 65 6c 20 2a 20 4c 6f | 6f 6b 75 70 4e 61 6d 65 |nel * Lo|okupName| |00005d80| 28 55 6e 69 78 53 6f 63 | 6b 65 74 41 64 64 72 20 |(UnixSoc|ketAddr | |00005d90| 6e 61 6d 65 29 0d 7b 0d | 09 73 68 6f 72 74 09 09 |name).{.|.short..| |00005da0| 09 09 66 69 6c 65 3b 0d | 09 48 61 6e 64 6c 65 09 |..file;.|.Handle.| |00005db0| 09 09 68 64 6c 3b 0d 09 | 55 6e 69 78 43 68 61 6e |..hdl;..|UnixChan| |00005dc0| 6e 65 6c 20 2a 09 63 75 | 72 09 3d 09 6e 69 6c 3b |nel *.cu|r.=.nil;| |00005dd0| 0d 09 55 6e 69 78 53 6f | 63 6b 65 74 49 44 09 69 |..UnixSo|cketID.i| |00005de0| 64 3b 0d 0d 09 66 69 6c | 65 09 3d 09 48 4f 70 65 |d;...fil|e.=.HOpe| |00005df0| 6e 52 65 73 46 69 6c 65 | 28 6e 61 6d 65 2e 76 52 |nResFile|(name.vR| |00005e00| 65 66 4e 75 6d 2c 20 6e | 61 6d 65 2e 70 61 72 49 |efNum, n|ame.parI| |00005e10| 44 2c 20 6e 61 6d 65 2e | 6e 61 6d 65 2c 20 66 73 |D, name.|name, fs| |00005e20| 52 64 50 65 72 6d 29 3b | 0d 0d 09 69 66 20 28 66 |RdPerm);|...if (f| |00005e30| 69 6c 65 20 21 3d 20 2d | 31 29 09 7b 0d 09 09 69 |ile != -|1).{...i| |00005e40| 66 20 28 68 64 6c 20 3d | 20 47 65 74 31 52 65 73 |f (hdl =| Get1Res| |00005e50| 6f 75 72 63 65 28 27 47 | 55 b7 49 27 2c 20 47 55 |ource('G|U.I', GU| |00005e60| 53 49 52 73 72 63 49 44 | 29 29 09 7b 0d 09 09 09 |SIRsrcID|)).{....| |00005e70| 69 64 20 3d 20 2a 2a 28 | 55 6e 69 78 53 6f 63 6b |id = **(|UnixSock| |00005e80| 65 74 49 44 20 2a 2a 29 | 20 68 64 6c 3b 0d 09 09 |etID **)| hdl;...| |00005e90| 09 0d 09 09 09 69 66 20 | 28 69 64 2e 56 61 6c 69 |.....if |(id.Vali| |00005ea0| 64 61 74 65 28 29 29 0d | 09 09 09 09 63 75 72 20 |date()).|....cur | |00005eb0| 3d 20 69 64 2e 63 68 61 | 6e 3b 0d 09 09 7d 0d 09 |= id.cha|n;...}..| |00005ec0| 09 43 6c 6f 73 65 52 65 | 73 46 69 6c 65 28 66 69 |.CloseRe|sFile(fi| |00005ed0| 6c 65 29 3b 0d 09 7d 0d | 09 0d 09 72 65 74 75 72 |le);..}.|...retur| |00005ee0| 6e 20 63 75 72 3b 0d 7d | 0d 00 00 00 00 00 00 00 |n cur;.}|........| |00005ef0| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| |00005f00| 00 00 01 00 00 00 02 78 | 00 00 01 78 00 00 00 74 |.......x|...x...t| |00005f10| 73 20 61 20 6e 69 63 65 | 20 6c 69 74 74 6c 65 20 |s a nice| little | |00005f20| 65 78 74 72 61 20 74 68 | 61 74 20 6d 61 6b 65 73 |extra th|at makes| |00005f30| 0b 47 55 53 49 55 6e 69 | 78 2e 63 70 02 00 00 00 |.GUSIUni|x.cp....| |00005f40| 54 45 58 54 4d 50 53 20 | 00 00 04 10 00 c0 00 00 |TEXTMPS |........| |00005f50| 00 00 54 45 58 54 4d 50 | 53 20 00 00 04 10 00 c0 |..TEXTMP|S ......| |00005f60| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| |00005f70| 00 00 a5 f5 5c d8 00 00 | 5e 69 00 00 02 ec 6c 69 |....\...|^i....li| |00005f80| 6e 67 20 61 6e 79 20 6f | 66 20 74 68 65 69 72 0d |ng any o|f their.| |00005f90| 20 20 20 20 20 20 20 20 | 63 61 6c 6c 20 62 61 63 | |call bac| |00005fa0| 6b 20 70 72 6f 63 65 64 | 75 72 65 73 2c 20 70 75 |k proced|ures, pu| |00005fb0| 73 68 65 73 20 74 68 65 | 20 65 78 74 72 61 20 70 |shes the| extra p| |00005fc0| 61 72 61 6d 65 74 65 72 | 20 6f 66 20 79 6f 75 72 |arameter| of your| |00005fd0| 44 61 74 61 50 74 72 20 | 6f 6e 0d 20 20 20 20 20 |DataPtr |on. | |00005fe0| 20 20 20 74 68 65 20 73 | 74 61 63 6b 2e 0d 20 20 | the s|tack.. | |00005ff0| 20 20 0d 20 20 20 20 20 | 20 20 20 49 6e 20 61 64 | . | In ad| |00006000| 00 00 00 78 00 01 00 00 | 00 48 00 48 00 00 00 00 |...x....|.H.H....| |00006010| 03 0c 02 40 ff e4 ff f7 | 03 2d 02 49 1f 03 05 7b |...@....|.-.I...{| |00006020| 03 de 00 01 00 00 01 2c | 01 2c 00 00 00 00 0c b2 |.......,|.,......| |00006030| 09 60 00 50 c0 00 00 64 | 0c 80 00 18 04 01 01 01 |.`.P...d|........| |00006040| 00 01 00 01 27 0f 00 01 | 01 01 00 00 00 00 00 00 |....'...|........| |00006050| 00 00 00 00 00 00 ff 3f | 00 00 00 00 00 00 00 00 |.......?|........| |00006060| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| |00006070| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 70 |........|.......p| |00006080| ec a8 b9 5d 3f e5 32 30 | 00 04 00 07 00 00 00 00 |...]?.20|........| |00006090| 00 00 a7 7f 18 2d a7 7f | 18 2d a6 71 49 ef 00 00 |.....-..|.-.qI...| |000060a0| bf be 00 01 00 11 00 06 | 05 47 55 53 49 ba 00 05 |........|.GUSI...| |000060b0| 6e 65 65 72 69 00 01 36 | 00 0b 47 55 53 49 55 6e |neeri..6|..GUSIUn| |000060c0| 69 78 2e 63 70 00 00 00 | 00 25 42 65 20 6d 6f 72 |ix.cp...|.%Be mor| |000060d0| 65 20 63 61 72 65 66 75 | 6c 20 61 62 6f 75 74 20 |e carefu|l about | |000060e0| 55 73 65 72 20 69 6e 74 | 65 72 72 75 70 74 73 00 |User int|errupts.| |000060f0| 00 00 00 48 00 09 4d 6f | 6e 61 63 6f 00 2a 2a 2a |...H..Mo|naco.***| |00006100| 2a 2a 2a 2a 2a 2a 2a 2a | 2a 2a 2a 2a 2a 2a 0d 50 |********|******.P| |00006110| 72 6f 6a 65 63 74 00 06 | 00 03 00 2d 00 17 01 ce |roject..|...-....| |00006120| 02 30 00 2d 00 17 01 ce | 02 30 a7 7f 7b ab 00 00 |.0.-....|.0..{...| |00006130| 4c c6 00 00 4c cd 00 00 | 4b 67 01 00 00 00 00 16 |L...L...|Kg......| |00006140| 00 01 00 00 03 13 00 00 | 03 48 0b 4c 61 73 74 43 |........|.H.LastC| |00006150| 68 61 6e 67 65 00 00 00 | 00 1e 00 2d 00 17 01 ce |hange...|...-....| |00006160| 02 30 00 2d 00 17 01 ce | 02 30 00 00 4b 67 00 00 |.0.-....|.0..Kg..| |00006170| 00 00 00 00 00 00 00 00 | 00 00 01 00 00 00 02 78 |........|.......x| |00006180| 00 00 01 78 00 00 00 74 | 00 31 aa b4 11 a2 00 00 |...x...t|.1......| |00006190| 00 1c 00 6a 00 01 4d 50 | 53 52 00 03 00 12 63 6b |...j..MP|SR....ck| |000061a0| 69 64 00 00 00 42 03 ee | ff ff 00 00 00 00 00 00 |id...B..|........| |000061b0| 00 00 03 ed ff ff 00 00 | 00 f0 00 00 00 00 03 ef |........|........| |000061c0| ff ff 00 00 01 3c 00 00 | 00 00 03 f0 ff ff 00 00 |.....<..|........| |000061d0| 01 56 00 37 e2 00 00 80 | 00 00 00 00 00 7c 00 00 |.V.7....|.....|..| |000061e0| 00 00 09 50 72 6f 6a 65 | 63 74 6f 72 00 00 00 00 |...Proje|ctor....| |000061f0| 00 00 00 00 00 00 00 00 | 00 00 00 00 00 00 00 00 |........|........| +--------+-------------------------+-------------------------+--------+--------+